org.apache.camel.component.hazelcast.atomicnumber
Class HazelcastAtomicnumberEndpoint

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint
              org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId

public class HazelcastAtomicnumberEndpoint
extends HazelcastDefaultEndpoint

Field Summary

Fields inherited from class org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint

cacheName

Constructor Summary

HazelcastAtomicnumberEndpoint(String uri, Component component, String cacheName)

Method Summary

Consumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Producer	createProducer() Creates a new producer which is used send messages into the endpoint

Methods inherited from class org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint

isSingleton

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

configureProperties, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

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

addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, 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

Constructor Detail

HazelcastAtomicnumberEndpoint

public HazelcastAtomicnumberEndpoint(String uri,
                                     Component component,
                                     String cacheName)

Method Detail

createConsumer

public Consumer createConsumer(Processor processor)
                        throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Specified by:

createConsumer in interface Endpoint

Specified by:

createConsumer in class HazelcastDefaultEndpoint

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Specified by:

createProducer in interface Endpoint

Specified by:

createProducer in class HazelcastDefaultEndpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown