org.apache.camel.component.quickfixj
Class QuickfixjEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.quickfixj.QuickfixjEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, QuickfixjEventListener, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class QuickfixjEndpoint
extends org.apache.camel.impl.DefaultEndpoint
implements QuickfixjEventListener, org.apache.camel.MultipleConsumersSupport

Field Summary

static String	DATA_DICTIONARY_KEY
static String	EVENT_CATEGORY_KEY
static String	MESSAGE_TYPE_KEY
static String	SESSION_ID_KEY

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

QuickfixjEndpoint(QuickfixjEngine engine, String uri, org.apache.camel.CamelContext context)
Deprecated.

QuickfixjEndpoint(QuickfixjEngine engine, String uri, org.apache.camel.Component component)

Method Summary

org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
protected void	doStop()
void	ensureInitialized() Initializing and starts the engine if it wasn't initialized so far.
QuickfixjEngine	getEngine()
quickfix.SessionID	getSessionID()
boolean	isMultipleConsumersSupported()
boolean	isSingleton()
void	onEvent(QuickfixjEventCategory eventCategory, quickfix.SessionID sessionID, quickfix.Message message)
void	setSessionID(quickfix.SessionID sessionID)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

EVENT_CATEGORY_KEY

public static final String EVENT_CATEGORY_KEY

See Also:

Constant Field Values

SESSION_ID_KEY

public static final String SESSION_ID_KEY

See Also:

Constant Field Values

MESSAGE_TYPE_KEY

public static final String MESSAGE_TYPE_KEY

See Also:

Constant Field Values

DATA_DICTIONARY_KEY

public static final String DATA_DICTIONARY_KEY

See Also:

Constant Field Values

Constructor Detail

QuickfixjEndpoint

@Deprecated
public QuickfixjEndpoint(QuickfixjEngine engine,
                                    String uri,
                                    org.apache.camel.CamelContext context)

Deprecated.

QuickfixjEndpoint

public QuickfixjEndpoint(QuickfixjEngine engine,
                         String uri,
                         org.apache.camel.Component component)

Method Detail

getSessionID

public quickfix.SessionID getSessionID()

setSessionID

public void setSessionID(quickfix.SessionID sessionID)

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Specified by:

createConsumer in interface org.apache.camel.Endpoint

Throws:

Exception

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Specified by:

createProducer in interface org.apache.camel.Endpoint

Throws:

Exception

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

onEvent

public void onEvent(QuickfixjEventCategory eventCategory,
                    quickfix.SessionID sessionID,
                    quickfix.Message message)
             throws Exception

Specified by:

onEvent in interface QuickfixjEventListener

Throws:

Exception

isMultipleConsumersSupported

public boolean isMultipleConsumersSupported()

Specified by:

isMultipleConsumersSupported in interface org.apache.camel.MultipleConsumersSupport

ensureInitialized

public void ensureInitialized()
                       throws Exception

Initializing and starts the engine if it wasn't initialized so far.

Throws:

Exception

getEngine

public QuickfixjEngine getEngine()

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultEndpoint

Throws:

Exception