com.caucho.hemp.services
Class BamJmsService

java.lang.Object
  extended by com.caucho.bam.stream.AbstractMessageStream
      extended by com.caucho.bam.actor.SimpleActor
          extended by com.caucho.hemp.services.BamJmsService
All Implemented Interfaces:
Actor, ActorHolder, ManagedActor, MessageStream

public class BamJmsService
extends SimpleActor

jms service


Constructor Summary
BamJmsService()
           
 
Method Summary
 void close()
           
 void init()
           
 void message(java.lang.String to, java.lang.String from, java.io.Serializable value)
          Sends to a queue
 void setConnectionFactory(ConnectionFactory factory)
          Sets the connection factory
 void setDestination(Destination queue)
          Sets the destination
 
Methods inherited from class com.caucho.bam.actor.SimpleActor
getActor, getAddress, getBroker, getMailbox, getSender, setAddress, setBroker, setMailbox
 
Methods inherited from class com.caucho.bam.stream.AbstractMessageStream
isClosed, messageError, query, queryError, queryResult, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.caucho.bam.stream.MessageStream
isClosed, messageError, query, queryError, queryResult
 

Constructor Detail

BamJmsService

public BamJmsService()
Method Detail

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 address
from - the source actor's address
value - the message payload

close

@PreDestroy
public void close()