org.robokind.impl.messaging
Class JMSBytesRecordBlockingReceiver

java.lang.Object
  extended by 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.
 
Method Summary
 int clearRecords()
           
 javax.jms.BytesMessage fetchRecord(long timeout)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JMSBytesRecordBlockingReceiver

public JMSBytesRecordBlockingReceiver(javax.jms.MessageConsumer consumer)
Creates a new JMSBytesRecordBlcokingReceiver which uses the given MessageConsumer.

Parameters:
consumer - MessageConsumer to fetch JMS BytesMessages
Method Detail

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.