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

Constructor Summary

Constructors

Constructor and Description
BamJmsService()

Method Summary

Modifier and Type	Method and Description
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()