org.jlab.coda.cMsg.apps

Class cMsgQueue

java.lang.Object

org.jlab.coda.cMsg.apps.cMsgQueue

public class cMsgQueue
extends java.lang.Object

This class is a general purpose cMsg queue utility that queues messages to a file OR a database. It stores the entire message in serialized binary, after payload compression. Payload is uncompressed when retrieving messages. For databases it additionally stores receipt time, creator, subject, type, userTime and userInt, allowing for selection criteria at some future date. To use with a database queue: java cMsgQueue -udl cMsg:cMsg://localhost/cMsg -name myQueue -url jdbc:mysql://halldweb1/test -driver com.mysql.jdbc.Driver -account fred To use with a file-based queue: java cMsgQueue -udl cMsg:cMsg://localhost/cMsg -name myQueue -dir myDir -base myFileBaseName

Version:

1.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	cMsgQueue.getCB Inner class to implement sendAndGet() callback.
(package private) static class	cMsgQueue.subscribeCB Inner class to implement subscribe callback.

Constructor Summary

Constructors

Constructor and Description
cMsgQueue()

Method Summary

Modifier and Type	Method and Description
(package private) static java.lang.String	getBlobName(java.sql.Connection conn) Gets blob name for this particular database.
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

cMsgQueue

public cMsgQueue()

Method Detail

main

public static void main(java.lang.String[] args)

getBlobName

static java.lang.String getBlobName(java.sql.Connection conn)

Gets blob name for this particular database.

Parameters:

conn - connection

Returns:

String containing blob name