com.adaptris.monitor.agent

Class UDPProfilerConsumer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageConsumerImp

com.adaptris.core.AdaptrisPollingConsumer

com.adaptris.monitor.agent.UDPProfilerConsumer

All Implemented Interfaces:

com.adaptris.core.AdaptrisComponent, com.adaptris.core.AdaptrisMessageConsumer, com.adaptris.core.AdaptrisMessageWorker, com.adaptris.core.ComponentLifecycle, com.adaptris.core.ComponentLifecycleExtension, com.adaptris.core.MessageEventGenerator, com.adaptris.core.StateManagedComponent

public class UDPProfilerConsumer
extends com.adaptris.core.AdaptrisPollingConsumer

Nested Class Summary

Nested classes/interfaces inherited from class com.adaptris.core.AdaptrisPollingConsumer

com.adaptris.core.AdaptrisPollingConsumer.LockOperator

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Fields inherited from interface com.adaptris.core.MessageEventGenerator

CONFIRMATION_ID_KEY

Constructor Summary

Constructors

Constructor and Description
UDPProfilerConsumer()

Method Summary

Modifier and Type	Method and Description
int	getPacketSize()
protected void	prepareConsumer()
void	processMessage(ActivityMap activityMap)
protected int	processMessages()
void	setPacketSize(int packetSize)

Methods inherited from class com.adaptris.core.AdaptrisPollingConsumer

close, continueProcessingMessages, getMaxMessagesPerPoll, getPoller, getReacquireLockBetweenMessages, init, prepare, releaseLock, setMaxMessagesPerPoll, setPoller, setReacquireLockBetweenMessages, start, stop

Methods inherited from class com.adaptris.core.AdaptrisMessageConsumerImp

changeState, getDestination, registerAdaptrisMessageListener, renameThread, requestClose, requestInit, requestStart, requestStop, retrieveAdaptrisMessageListener, retrieveComponentState, setDestination

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createName, createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.AdaptrisMessageConsumer

consumeLocationKey

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createName, createQualifier, isTrackingEndpoint

Constructor Detail

UDPProfilerConsumer

public UDPProfilerConsumer()

Method Detail

prepareConsumer

protected void prepareConsumer()
                        throws com.adaptris.core.CoreException

Specified by:

prepareConsumer in class com.adaptris.core.AdaptrisPollingConsumer

Throws:

com.adaptris.core.CoreException

getPacketSize

public int getPacketSize()

setPacketSize

public void setPacketSize(int packetSize)

processMessages

protected int processMessages()

Specified by:

processMessages in class com.adaptris.core.AdaptrisPollingConsumer

processMessage

public void processMessage(ActivityMap activityMap)