Listing 2. LJEventChannel.java
import org.omg.CosNaming.*;
import org.omg.CosEventComm.*;
import org.omg.CosEventChannelAdmin.*;
import com.visigenic.vbroker.services.CosEvent.*;
import java.io.DataInputStream;
import org.omg.CORBA.SystemException;
import java.util.*;
import logging.*;
class LogServiceImpl extends _PushSupplierImplBase
implements LogServiceOperations
{
private org.omg.CORBA.ORB orb;
private org.omg.CORBA.BOA boa;
private PushConsumer _pushConsumer;
public void disconnect_push_supplier() {
System.out.println(
"LogServiceImpl.disconnect_push_supplier() called");
try {
boa.deactivate_obj(this);
}
catch(org.omg.CORBA.SystemException e) {
e.printStackTrace();
}
}
LogServiceImpl()
{
System.out.println(
"in LogServiceImpl constructor, creating EventChannel");
String[] args = null;
try
{
orb = org.omg.CORBA.ORB.init(args, null);
boa = orb.BOA_init();
EventChannel channel = null;
ProxyPushConsumer pushConsumer = null;
try
{
String name = args[0];
System.out.println(
"In LogServiceImpl: binding to channel_server");
channel = EventChannelHelper.bind(orb,
"channel_server");
System.out.println(
"Created event channel: " + channel);
if(channel == null)
{
System.out.println(
"ERROR: Failed to bind to Event Channel ... bailing");
}
else
{
pushConsumer =
channel.for_suppliers().obtain_push_consumer();
System.out.println(
"Obtained push consumer: " + pushConsumer);
}
if(pushConsumer == null)
{
System.out.println(
"ERROR: failed to obtain push consumer");
}
else
{
PushConsumer clone =
PushConsumerHelper.narrow(pushConsumer._clone());
_pushConsumer = clone;
System.out.println(
"Connecting to Push Supplier ...");
pushConsumer.connect_push_supplier(this);
}
}
catch(org.omg.CORBA.SystemException e)
{
e.printStackTrace();
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
public void send(String str)
{
try
{
org.omg.CORBA.Any message = orb.create_any();
message.insert_string(str);
System.out.println(
"Supplier pushing: " + message);
_pushConsumer.push(message);
}
catch(Disconnected e)
{
System.out.println("Disconnected");
}
catch(SystemException e)
{
e.printStackTrace();
disconnect_push_supplier();
}
}
}
public class LJEventChannel
{
public static void main(String[] args)
{
org.omg.CORBA.ORB orb =
org.omg.CORBA.ORB.init(args,null);
org.omg.CORBA.BOA boa =
orb.BOA_init();
// create the logging server
LogServiceImpl new_service =
new LogServiceImpl();
LogService service =
new _tie_LogService(new_service,
"LogService");
if( service == null )
System.out.println(
"service is NULL!!!!!");
try
{
org.omg.CORBA.Object objRef =
orb.resolve_initial_references("NameService");
org.omg.CosNaming.NamingContext rootContext =
org.omg.CosNaming.NamingContextHelper.narrow(objRef);
NameComponent comp1 = new NameComponent(
"Linux Journal","");
NameComponent [] name = {comp1};
NamingContext ljcontext =
rootContext.bind_new_context(name);
NameComponent comp2 = new NameComponent(
"LJEventChannel","ec");
NameComponent [] name2 = {comp2};
ljcontext.rebind(name2,service);
}
catch(Exception e)
{
System.out.println("Exception: " + e);
}
// export the object reference
boa.obj_is_ready(service);
System.out.println(service + " is ready.");
// wait for requests
boa.impl_is_ready();
}
}
Copyright © 1994 - 2018 Linux Journal. All rights reserved.