org.logicblaze.lingo.jms
Class JmsClient
java.lang.Object
org.logicblaze.lingo.jms.JmsClient
public class JmsClient
- extends Object
A helper class for working with JMS from inside collection classes
- Version:
- $Revision$
Constructor Summary |
JmsClient()
|
JmsClient(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination destination)
|
JmsClient(javax.jms.Destination destination,
JmsProducer producer,
javax.jms.MessageConsumer consumer)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsClient
public JmsClient()
JmsClient
public JmsClient(javax.jms.ConnectionFactory connectionFactory,
javax.jms.Destination destination)
JmsClient
public JmsClient(javax.jms.Destination destination,
JmsProducer producer,
javax.jms.MessageConsumer consumer)
receiveNoWait
public javax.jms.Message receiveNoWait()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
receive
public javax.jms.Message receive()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
receive
public javax.jms.Message receive(long timeout,
edu.emory.mathcs.backport.java.util.concurrent.TimeUnit unit)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createBrowser
public javax.jms.QueueBrowser createBrowser()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
peek
public javax.jms.Message peek()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
send
public void send(javax.jms.Message message)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createMessage
public javax.jms.Message createMessage(Object element)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
handleException
public void handleException(javax.jms.JMSException e)
readMessage
public Object readMessage(javax.jms.Message message)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
close
public void close(javax.jms.QueueBrowser browser)
close
public void close()
getConsumer
public javax.jms.MessageConsumer getConsumer()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
setConsumer
public void setConsumer(javax.jms.MessageConsumer consumer)
getDestination
public javax.jms.Destination getDestination()
setDestination
public void setDestination(javax.jms.Destination destination)
getMarshaller
public Marshaller getMarshaller()
setMarshaller
public void setMarshaller(Marshaller marshaller)
getProducer
public JmsProducer getProducer()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
setProducer
public void setProducer(JmsProducer producer)
getConfig
public JmsProducerConfig getConfig()
setConfig
public void setConfig(JmsProducerConfig config)
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
setConnectionFactory
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
isNoLocal
public boolean isNoLocal()
setNoLocal
public void setNoLocal(boolean noLocal)
- Sets if messages sent by this process should be visible to this JVM
getSelector
public String getSelector()
setSelector
public void setSelector(String selector)
- Sets the JMS message selector to filter out messages from the consumer
onBrowserCloseException
protected void onBrowserCloseException(javax.jms.JMSException e)
Copyright © 2012 LogicBlaze, Inc.. All Rights Reserved.