org.apache.camel.component.salesforce.internal.streaming
Class SubscriptionHelper

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper
All Implemented Interfaces:
org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class SubscriptionHelper
extends org.apache.camel.support.ServiceSupport


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
SubscriptionHelper(SalesforceComponent component)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 String getEndpointUrl()
           
 void subscribe(String topicName, SalesforceConsumer consumer)
           
 void unsubscribe(String topicName, SalesforceConsumer consumer)
           
 
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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SubscriptionHelper

public SubscriptionHelper(SalesforceComponent component)
                   throws Exception
Throws:
Exception
Method Detail

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class org.apache.camel.support.ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class org.apache.camel.support.ServiceSupport
Throws:
Exception

subscribe

public void subscribe(String topicName,
                      SalesforceConsumer consumer)
               throws org.apache.camel.CamelException
Throws:
org.apache.camel.CamelException

unsubscribe

public void unsubscribe(String topicName,
                        SalesforceConsumer consumer)
                 throws org.apache.camel.CamelException
Throws:
org.apache.camel.CamelException

getEndpointUrl

public String getEndpointUrl()


Apache Camel