org.robokind.impl.messaging
Class JMSBytesRecordBlockingReceiver
java.lang.Object
org.robokind.impl.messaging.JMSBytesRecordBlockingReceiver
- All Implemented Interfaces:
- org.robokind.api.messaging.RecordBlockingReceiver<javax.jms.BytesMessage>
public class JMSBytesRecordBlockingReceiver
- extends Object
- implements org.robokind.api.messaging.RecordBlockingReceiver<javax.jms.BytesMessage>
Blocks and waits for a JMS BytesMessage when called.
- Author:
- Matthew Stevenson
Constructor Summary |
JMSBytesRecordBlockingReceiver(javax.jms.MessageConsumer consumer)
Creates a new JMSBytesRecordBlcokingReceiver which uses the given
MessageConsumer. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JMSBytesRecordBlockingReceiver
public JMSBytesRecordBlockingReceiver(javax.jms.MessageConsumer consumer)
- Creates a new JMSBytesRecordBlcokingReceiver which uses the given
MessageConsumer.
- Parameters:
consumer
- MessageConsumer to fetch JMS BytesMessages
fetchRecord
public javax.jms.BytesMessage fetchRecord(long timeout)
- Specified by:
fetchRecord
in interface org.robokind.api.messaging.RecordBlockingReceiver<javax.jms.BytesMessage>
clearRecords
public int clearRecords()
- Specified by:
clearRecords
in interface org.robokind.api.messaging.RecordBlockingReceiver<javax.jms.BytesMessage>
Copyright © 2011-2013. All Rights Reserved.