Package | Description |
---|---|
com.yourmediashelf.fedora.client.messaging |
This package is essentially the same as org.fcrepo.client.messaging but
without all of the org.fcrepo.server and org.fcrepo.common dependencies
(as none of the org.fcrepo artifacts are actually available in a Maven
repository as of 2010-07-05).
|
Modifier and Type | Method and Description |
---|---|
void |
JMSManager.close() |
protected void |
JMSManager.connectToJMS(String clientId) |
javax.jms.BytesMessage |
JMSManager.createBytesMessage(String destName) |
javax.jms.Destination |
JMSManager.createDestination(String name,
JMSManager.DestinationType type)
Creates a Destination.
|
javax.jms.Destination |
JMSManager.createDestination(String name,
JMSManager.DestinationType type,
boolean fTransacted,
int ackMode)
Creates a Destination if the Destination has not already been created.
|
javax.jms.MapMessage |
JMSManager.createMapMessage(String destName) |
javax.jms.ObjectMessage |
JMSManager.createObjectMessage(String destName,
Serializable object) |
javax.jms.TextMessage |
JMSManager.createTextMessage(String destName,
String text) |
protected javax.jms.Connection |
JMSManager.getConnection() |
javax.jms.MessageConsumer |
JMSManager.getConsumer(String destName) |
protected Context |
JMSManager.getContext() |
javax.jms.Destination |
JMSManager.getDestination(String destName)
Gets the named Destination if it has been created.
|
protected com.yourmediashelf.fedora.client.messaging.JMSManager.JMSDestination |
JMSManager.getJMSDestination(String name) |
javax.jms.MessageProducer |
JMSManager.getProducer(String destName) |
javax.jms.Session |
JMSManager.getSession(String destName) |
protected Object |
JMSManager.jndiLookup(String name) |
javax.jms.Message |
JMSManager.listen(javax.jms.Destination dest)
Convenience method for synchronous listen with no message selector
|
void |
JMSManager.listen(javax.jms.Destination dest,
javax.jms.MessageListener callback)
This is an asynchronous listen.
|
javax.jms.Message |
JMSManager.listen(javax.jms.Destination dest,
String messageSelector)
This is a synchronous listen.
|
void |
JMSManager.listen(javax.jms.Destination dest,
String messageSelector,
javax.jms.MessageListener callback)
This is an asynchronous listen.
|
javax.jms.Message |
JMSManager.listen(String destName)
Convenience method for synchronous listen with no message selector
|
javax.jms.Message |
JMSManager.listen(String destName,
int timeout)
Convenience method for synchronous listen with no message selector
|
void |
JMSManager.listen(String destName,
javax.jms.MessageListener callback)
Convenience method for asynchronous listen with no message selector
|
javax.jms.Message |
JMSManager.listen(String destName,
String messageSelector)
This is a synchronous listen.
|
javax.jms.Message |
JMSManager.listen(String destName,
String messageSelector,
int timeout)
This is a synchronous listen.
|
void |
JMSManager.listen(String destName,
String messageSelector,
javax.jms.MessageListener callback)
This is an asynchronous listen.
|
String |
JMSManager.listenDurable(String topic,
javax.jms.MessageListener callback) |
String |
JMSManager.listenDurable(String topicName,
javax.jms.MessageListener callback,
String subscriptionName) |
String |
JMSManager.listenDurable(javax.jms.Topic topic,
javax.jms.MessageListener callback)
This is a convenience method to allow a durable subscription to be
created using the topic as the subscription name.
|
String |
JMSManager.listenDurable(javax.jms.Topic topic,
String messageSelector,
javax.jms.MessageListener callback,
String subscriptionName)
This is an asynchronous and durable listen.
|
void |
JMSManager.send(javax.jms.Destination dest,
javax.jms.Message msg)
Allows the caller to send a Message object to a destination
|
void |
JMSManager.send(String destName,
javax.jms.Message msg)
Allows the caller to send a Message object to a named destination
|
void |
JMSManager.send(String destName,
Serializable obj)
Allows the caller to send a Serializable object to a destination
|
void |
JMSManager.send(String destName,
String messageText)
Allows the caller to send text to a destination
|
protected void |
JMSManager.setupAsynchConsumer(com.yourmediashelf.fedora.client.messaging.JMSManager.JMSDestination jmsDest,
String messageSelector,
javax.jms.MessageListener callback) |
protected void |
JMSManager.setupProducer(com.yourmediashelf.fedora.client.messaging.JMSManager.JMSDestination jmsDest) |
protected javax.jms.Message |
JMSManager.setupSynchConsumer(com.yourmediashelf.fedora.client.messaging.JMSManager.JMSDestination jmsDest,
String messageSelector,
int timeout) |
void |
MessagingClient.start()
Starts the MessagingClient.
|
void |
MessagingClient.start(boolean wait)
Starts the MessagingClient.
|
void |
MessagingClient.stop(boolean unsubscribe)
Stops the MessagingClient, shuts down connections.
|
void |
JMSManager.stop(String destName)
Stops producers and consumers on a given destination.
|
void |
JMSManager.stopDurable(String subscriptionName)
Stops a durable message consumer.
|
void |
JMSManager.unsubscribeAllDurable()
Removes all durable topic subscriptions created using
this JMSManager instance
|
void |
JMSManager.unsubscribeDurable(String subscriptionName)
Removes the durable subscription with the given name.
|
Constructor and Description |
---|
JMSManager(Properties jndiProps)
Creates a JMS manager using jndi properties to start a connection
to a JMS provider.
|
JMSManager(Properties jndiProps,
String clientId)
Creates a JMS manager using jndi properties to start a connection
to a JMS provider.
|
MessagingClient(String clientId,
MessagingListener listener,
Properties connectionProperties)
Creates a messaging client
|
MessagingClient(String clientId,
MessagingListener listener,
Properties connectionProperties,
boolean durable)
Creates a messaging client
|
MessagingClient(String clientId,
MessagingListener listener,
Properties connectionProperties,
String messageSelector,
boolean durable)
Creates a messaging client
|
Copyright © 2010-2013 MediaShelf. All Rights Reserved.