com.caucho.hemp.services
Class BamJmsService
java.lang.Object
com.caucho.bam.stream.AbstractMessageStream
com.caucho.bam.actor.SimpleActor
com.caucho.hemp.services.BamJmsService
- All Implemented Interfaces:
- Actor, ActorHolder, ManagedActor, MessageStream
public class BamJmsService
- extends SimpleActor
jms service
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
BamJmsService
public BamJmsService()
setConnectionFactory
public void setConnectionFactory(ConnectionFactory factory)
- Sets the connection factory
setDestination
public void setDestination(Destination queue)
- Sets the destination
init
@PostConstruct
public void init()
throws JMSException
- Throws:
JMSException
message
public void message(java.lang.String to,
java.lang.String from,
java.io.Serializable value)
- Sends to a queue
- Specified by:
message
in interface MessageStream
- Overrides:
message
in class AbstractMessageStream
- Parameters:
to
- the target actor's addressfrom
- the source actor's addressvalue
- the message payload
close
@PreDestroy
public void close()