EventChannel.idl100644 764 764 155 6705521516 13425 0ustar jmshackjmshack// EventChannel.idl module logging { interface LogService { void send(in string str); }; }; LJEventChannel.java100664 764 764 7376 6705521516 14062 0ustar jmshackjmshack// 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(); } } Makefile100640 764 764 575 6705521516 12023 0ustar jmshackjmshack# Makefile .SUFFIXES: .java .class .idl .module .java.class: vbjc $< .idl.module: idl2java $< touch $@ default: all clean: rm -rf logging rm -f *.class *.tmp *.module *~ IDLS = \ EventChannel.idl MODULES = $(IDLS:.idl=.module) SRCS = \ PullConsumer.java \ PushSupplier.java \ LJEventChannel.java CLASSES = $(SRCS:.java=.class) all: $(MODULES) $(CLASSES) PullConsumer.java100644 764 764 3441 6705521516 13675 0ustar jmshackjmshack// PullConsumer.java import org.omg.CosEventComm.*; import org.omg.CosEventChannelAdmin.*; import com.visigenic.vbroker.services.CosEvent.*; import java.io.DataInputStream; public class PullConsumer extends _PullConsumerImplBase { public void disconnect_pull_consumer() { System.out.println("PullConsumer.disconnect_pull_consumer called"); } public static void main(String[] args) { try { org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init(args, null); org.omg.CORBA.BOA boa = orb.BOA_init(); EventChannel channel = null; PullConsumer ljPullConsumer = null; ProxyPullSupplier pullSupplier = null; DataInputStream in = new DataInputStream(System.in); System.out.println("about to call bind on channel_server"); channel = EventChannelHelper.bind(orb,"channel_server"); System.out.println("Located event channel: " + channel); ljPullConsumer = new PullConsumer(); boa.obj_is_ready(ljPullConsumer); System.out.println("Created ljPullConsumer: " + ljPullConsumer); pullSupplier = channel.for_consumers().obtain_pull_supplier(); System.out.println("Obtained pull supplier: " + pullSupplier); System.out.println("Connecting..."); System.out.flush(); pullSupplier.connect_pull_consumer(ljPullConsumer); System.out.println("Consumer entering Event Pull Loop..."); org.omg.CORBA.BooleanHolder hasEvent = new org.omg.CORBA.BooleanHolder(); org.omg.CORBA.Any result = null; while(true) { while(!hasEvent.value) { result = pullSupplier.try_pull(hasEvent); } System.out.println("Consumer pulled event: " + result.toString()); hasEvent.value = false; } } catch(Exception e) { e.printStackTrace(); } } } PushSupplier.java100644 764 764 3402 6705521516 13705 0ustar jmshackjmshack// PushSupplier.java import org.omg.CosNaming.*; import logging.*; public class PushSupplier { public static void main(String args[]) { // Initiliaze the ORB. org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init(args,null); String logname; if( args.length > 0 ) logname = args[0]; else logname = "default supplier"; // bind to the Log Service //LogService logger = LogServiceHelper.bind(orb, "LogService"); LogService logger = 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 comp2 = new NameComponent("LJEventChannel","ec"); NameComponent [] name = {comp1, comp2}; org.omg.CORBA.Object rObjRef = rootContext.resolve(name); logger = LogServiceHelper.narrow(rObjRef); } catch(Exception e) { System.out.println("Exception: " + e); } if( logger == null ) { System.out.println("logger is null"); return; } else System.out.println("logger is NOT null"); System.out.println("bound the Log Service"); // use user-supplied args as the supplier's name, or use a default. System.out.println("supplier [" + logname + "] entering send loop"); while(true) { try { System.out.println("supplier [" + logname + "] sending a string now..."); logger.send("this is the string from supplier [" + logname + "]"); Thread.sleep(2000); } catch( InterruptedException e ) { System.out.println("Received InterruptedException: " + e); } } } } README.FIRST!100664 764 764 1173 6706761007 12215 0ustar jmshackjmshackFirst, read the README.install file. Then, read the README.bin.dir file. After this, you should have everything downloaded, installed, and set up. Then, you can build the example (following README.install). After that, follow the instructions in README.run in order to run the example application. Make sure you read the README.bin.dir file, which contains information on running the applications, once built. In particular, it stresses that you need a working KORN shell to run the applications, and the VisiBroker scripts will not work as-is if you simply try to run them under the Bash shell, which is the Linux default shell. README.bin.dir100664 764 764 1510 6705521516 12603 0ustar jmshackjmshackIf you followed the instructions in README.install, these files were taken as-is from the Solaris port of VisiBroker for Java 3.4. They rely on a functioning Korn shell. They should work with any capable Korn shell, including both pdksh (the Linux default, a Korn88 implementation), as well as the ksh93 (Version 12/28/93f) port by David Korn et. al. from AT&T. You can find the latter for Linux at http://www.research.att.com/sw/tools/reuse/. Go there and then click on the "Binary" button under the "Non-Commercial License Agreement and Available Software" heading. Then choose "ast-base-97" by selecting your operating system (UNIX: Linux 2.0 ELF). Then, fill out the licensing info and click on the "Accept License and Download Now" button. You can take it from there. This will provide you with a Korn93 implementation on Linux. README.install100664 764 764 17377 6705630336 12767 0ustar jmshackjmshackThe setup for the build environment takes a few steps. First of all, you want to make sure you have the JDK from blackdown.org. It can be obtained by visiting http://www.blackdown.org/java-linux.html, and choosing to "Download the JDK for Linux." Follow the installation instructions in Blackdown's documentation. You want to make sure that you get the jdk 1.1.7, and not 1.2. Installing VisiBroker for Java on Linux is a little more complicated. The problem is that VisiBroker has an executable called "osagent" that must be running in order to fully operate the ORB. Unfortunately, there is as of yet no "official" Linux port of VisiBroker for Java, and thus no ELF binary of osagent that runs on Linux natively. If you'd like to let the folks at Inprise know how nice it would be to have a pure Linux port of their product, Inprise suggests you send email to the following email address: pjonusaitis@inprise.com. For now, however, you must run the osagent under one of their supported platforms, which includes Windows, Solaris, HPUX, AIX, Digital Unix and IRIX, but not Linux. Therefore, you can do all your VisiBroker for Java development on Linux and run all your CORBA applications on linux machines, but you have to run osagent on a supported platform. This leads us to several options, one of which we'll describe here here. Among your options are: 1. Use a network, with a minimum of 1 Linux Box (any flavor) and one other machine that is running either Windows (any flavor), Solaris, HPUX, AIX, or IRIX. All your development and execution will be done on the linux box, but the "other" machine will run osagent. 2. Use Wine for Linux to run osagent directly on the Linux box. See http://www.winehq.com/ for more information on downloading, installation, and setup. This option would not require a network, but would require obtaining and configuring Wine. 3. Use vmware, and set up a virtual machine running Windows on your Linux box, and run osagent within the Windows virtual machine. Check them out at http://www.vmware.com/. This option would not require a physical network (it utilizes a virtual network address in the VM), but would require installing vmware and configuring the VM and then installing a Windows operating system into the VM, such as Windows 95/98 or NT. For our discussion here, we have chosen the first option. We will use a small network consisting simply of a single Linux box and a single Windows 95 box (a typical small home network). We will install VisiBroker for Java on the Windows 95 machine, and then "port" it over (mainly the .jar files) to the Linux box. If you are using another box with other than Windows, just substitute that OS for Windows in the instructions below. First, make sure you have installed the JDK from Blackdown, as mentioned above. Next, download the 60-day trial version of VisiBroker for Java for Windows from Inprise, by going to http://www.inprise.com/visibroker/download/, and choosing to download VisiBroker for Java for Windows (or whatever your second "official" box is going to be). As of the time of this writing, version 3.4 is available for Windows. Install the jdk according to the instructions that accompany it. (Mark the page, becuase you may need to return to it and download the Solaris version as well, to get the vbroker/bin directory--see below). Now, you must install VisiBroker for Java onto the Windows box. You must do this for two reasons. One, we're going to be running osagent on the Windows box, since it's an executable not available for Linux. Secondly, the official installation process stamps the VisiBroker jar files with a license code that is necessary for the proper operation of the ORB. If these files are not installed properly, they will not run. Therefore, installation of VisiBroker onto a supported machine is a necessity, so that the jar files can be properly stamped. So, install VisiBroker into a directory (perhaps c:\vbroker) on the Windows machine. Then, copy the files from c:\vbroker to your linux box (say, under /opt/vbroker). You can do this in several different ways. Perhaps the easiest is to use Samba on the linux box to server up SMB drives for the Windows box. Another way is to use nfs to do the transfer (either running an nfs client on the Windows box or an nfs server on the Windows box). A third way is to zip up the entire vbroker directory structure, and ftp that tarball over to the linux box, and untar it into /opt/vbroker. However you choose to do it, you want to get the following directories over onto the linux box at a minimum (some of these are not strictly necessary, but they are nice to have): c:\vbroker\lib ===> /opt/vbroker/lib c:\vbroker\adm ===> /opt/vbroker/adm c:\vbroker\docs ===> /opt/vbroker/docs c:\vbroker\idl ===> /opt/vbroker/idl c:\vbroker\java_examples ===> /opt/vbroker/java_examples Your /opt/vbroker/lib will contain the license-stamped jar files for the VisiBroker ORB. Now, you still need an /opt/vbroker/bin directory. This is a little problematic, because you can't simply copy over the Windows c:\vbroker\bin directory, because it contains windows binaries, which will do you no good. So, your best bet is to download (yes, again) the Solaris port of the VisiBroker for Java 3.4, and extract it's /vbroker/bin directory from the tarball. The way to do that is as follows: 1. Download the Solaris VisiBroker 3.4 file called vbj34_sol.tar, from the Inprise web site, where you downloaded the Windows version earlier. 2. Create a directory called vbj34.sol, and change to that directory. 3. Untar the tarball: tar ../vbj34_sol.tar 4. Uncompress the files ending with .Z with this command: uncompress *.Z 5. Then, extract three of the files with the following commands: tar xvf vbcrdev.tar tar xvf vbcrrun.tar tar xvf vbgkrun.tar 6. Now, on you Linux machine, create a new bin directory under your /opt/vbroker directory where you copied all your files from the Windows installation. 7. Then, copy the contents of the vbj34.sol/bin directory to your target vbroker/bin directory, something like: cp vbj34.sol/bin/* /opt/vbroker/bin 8. After doing this, you should have the following files in your /opt/vbroker/bin directory: gatekeeper idl2java java2iiop oadutil printIOR vbj_convert gkconfig irep locserv osagent vbdebug vbjc idl2ir java2idl oadj osfind vbj vbver The only files among these that you will need to use for our example are idl2java, vbjc, and vbj. Read the README.bin.dir file, that's our description file for the ported bin directory. Note that some of these files, such as osagent and osfind, are Solaris binaries, so don't try and run them. Now, you should have the JDK1.1.7 installed, say in /usr/local/jdk117_v1a. You should also have copied over the VisiBroker directories listed above, say into /opt/vbroker. At this point, you want to make sure that (based on the above sample directories) you have the following setup: Your PATH should include the following: /usr/local/jdk117_v1a/bin /opt/vbroker/bin You can verify the above by typing the commands "which javac" and "which vbj". The javac should resolve to your jdk bin directory, and your vbj should resolve to your vbroker bin directory. Your CLASSPATH should include the following: /usr/local/jdk117_v1a/lib/classes.zip /opt/vbroker/lib/swingall.jar /opt/vbroker/lib/vbjtools.jar /opt/vbroker/lib/vbjapp.jar /opt/vbroker/lib/vbjorb.jar /opt/vbroker/lib/vbjcosnm.jar /opt/vbroker/lib/vbjcosev.jar Once you have the above set up, building the source is quite simple. Just download it and untar it into a new directory, and type "make". That will build the source. For instructions on how to run the application once built, see the README.run file. README.run100644 764 764 2036 6705521516 12064 0ustar jmshackjmshackPreparation: Make sure that you have included the current directory in your CLASSPATH. Then, to run: start Smart Agent on the Windows machine (or Solaris, HP, whatever) run VB event service: vbj com.visigenic.vbroker.services.CosEvent.Channel channel_server run VB naming service: vbj -DORBservices=CosNaming -DSVCnameroot=VBOnLinux com.visigenic.vbroker.services.CosNaming.ExtFactory VBOnLinux namingLog Then, run: vbj -DORBservices=CosNaming -DSVCnameroot=VBOnLinux LJEventChannel vbj -DORBservices=CosNaming -DSVCnameroot=VBOnLinux PushSupplier 10 vbj PullConsumer NOTES: You might then want to kick off another PushSuplier (with another id, something like "20" or "Windows2", etc. and watch how a single consumer receives data from multiple suppliers. You might then want to kick off a second PullConsumer, and watch how the VB event service uses a Round Robin delivery mechanism to service all suppliers and consumers dedicated to the same channel (channel_server). Suppliers and Consumers may be run equally on Windows and/or Linux.