edu.sc.seis.crocus.rabbitmq

Class CachingMSeedConsumer

java.lang.Object

com.rabbitmq.client.DefaultConsumer

edu.sc.seis.crocus.rabbitmq.CachingMSeedConsumer

All Implemented Interfaces:

com.rabbitmq.client.Consumer

public class CachingMSeedConsumer
extends com.rabbitmq.client.DefaultConsumer

Constructor Summary

Constructors

Constructor and Description
CachingMSeedConsumer(com.rabbitmq.client.Channel channel, MSeedRequestClient client)

Method Summary

Modifier and Type	Method and Description
void	handleDelivery(java.lang.String consumerTag, com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body)
void	newRequest(java.lang.String corrId, ChannelTimeWindow ctw)

Methods inherited from class com.rabbitmq.client.DefaultConsumer

getChannel, getConsumerTag, handleCancel, handleCancelOk, handleConsumeOk, handleRecoverOk, handleShutdownSignal

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingMSeedConsumer

public CachingMSeedConsumer(com.rabbitmq.client.Channel channel,
                            MSeedRequestClient client)

Method Detail

handleDelivery

public void handleDelivery(java.lang.String consumerTag,
                           com.rabbitmq.client.Envelope envelope,
                           com.rabbitmq.client.AMQP.BasicProperties properties,
                           byte[] body)
                    throws java.io.IOException

Specified by:

handleDelivery in interface com.rabbitmq.client.Consumer

Overrides:

handleDelivery in class com.rabbitmq.client.DefaultConsumer

Throws:

java.io.IOException

newRequest

public void newRequest(java.lang.String corrId,
                       ChannelTimeWindow ctw)