org.robokind.impl.messaging
Class JMSBytesMessageSender

java.lang.Object
  org.robokind.impl.messaging.JMSBytesMessageSender

All Implemented Interfaces:

org.robokind.api.messaging.RecordSender<javax.jms.BytesMessage>

public class JMSBytesMessageSender
extends Object
implements org.robokind.api.messaging.RecordSender<javax.jms.BytesMessage>

Author:

Matthew Stevenson

Constructor Summary

JMSBytesMessageSender()
Creates an empty JMSBytesSender.

Method Summary

void	closeProducer() Closes the underlying JMS MessageProducer making it unable to send Records.
void	openProducer() Opens the underlying JMS MessageProducer, allowing it to begin sending Records.
void	sendRecord(javax.jms.BytesMessage message) Sends a BytesMessage
void	setDestination(javax.jms.Destination dest) Sets the JMS Destination to send to.
void	setSession(javax.jms.Session session) Sets the JMS Session to use for sending

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSBytesMessageSender

public JMSBytesMessageSender()

Creates an empty JMSBytesSender.

Method Detail

setSession

public void setSession(javax.jms.Session session)

Sets the JMS Session to use for sending

Parameters:

session -

setDestination

public void setDestination(javax.jms.Destination dest)

Sets the JMS Destination to send to.

Parameters:

dest - JMS Destination to send to

closeProducer

public void closeProducer()

Closes the underlying JMS MessageProducer making it unable to send Records.

openProducer

public void openProducer()

Opens the underlying JMS MessageProducer, allowing it to begin sending Records. This must be called before Records can be sent.

sendRecord

public void sendRecord(javax.jms.BytesMessage message)

Sends a BytesMessage

Specified by:

sendRecord in interface org.robokind.api.messaging.RecordSender<javax.jms.BytesMessage>

Parameters:

bytes - byte array to send from