org.mule.modules.salesforce.streaming

Class StreamingClient

java.lang.Object

org.mule.modules.salesforce.streaming.StreamingClient

public class StreamingClient
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamingClient(ProxyDTO proxy, BayeuxParameters bayeuxParameters, org.mule.api.MuleContext muleContext, SubscribeParams subscribeParams, SessionControl sessionControl)

Method Summary

Modifier and Type	Method and Description
Boolean	isForceResubscribe()
void	start()
void	stop()
void	subscribe(String topic, long replayFrom, org.cometd.bayeux.client.ClientSessionChannel.MessageListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingClient

public StreamingClient(ProxyDTO proxy,
                       BayeuxParameters bayeuxParameters,
                       org.mule.api.MuleContext muleContext,
                       SubscribeParams subscribeParams,
                       SessionControl sessionControl)

Method Detail

isForceResubscribe

public Boolean isForceResubscribe()

start

public void start()

subscribe

public void subscribe(String topic,
                      long replayFrom,
                      org.cometd.bayeux.client.ClientSessionChannel.MessageListener listener)

stop

public void stop()