org.mule.modules.salesforce

Class SalesforceBayeuxClient

java.lang.Object

org.cometd.common.AbstractClientSession

org.cometd.client.BayeuxClient

org.mule.modules.salesforce.SalesforceBayeuxClient

All Implemented Interfaces:

org.cometd.bayeux.Bayeux, org.cometd.bayeux.client.ClientSession, org.cometd.bayeux.Session, org.eclipse.jetty.util.component.Dumpable

public class SalesforceBayeuxClient
extends org.cometd.client.BayeuxClient

SalesforceBayeuxClient is an extension of a BayeuxClient that can deal with Salesforce session management.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SalesforceBayeuxClient.StreamingMessageConnectListener
class	SalesforceBayeuxClient.StreamingMessageHandshakeListener Listener for /meta/handshake messages notifying about the handshake result.

Nested classes/interfaces inherited from class org.cometd.client.BayeuxClient

org.cometd.client.BayeuxClient.BayeuxClientChannel, org.cometd.client.BayeuxClient.State

Nested classes/interfaces inherited from class org.cometd.common.AbstractClientSession

org.cometd.common.AbstractClientSession.AbstractSessionChannel

Nested classes/interfaces inherited from interface org.cometd.bayeux.Bayeux

org.cometd.bayeux.Bayeux.BayeuxListener

Nested classes/interfaces inherited from interface org.cometd.bayeux.client.ClientSession

org.cometd.bayeux.client.ClientSession.Extension, org.cometd.bayeux.client.ClientSession.MessageListener

Field Summary

Fields inherited from class org.cometd.client.BayeuxClient

BACKOFF_INCREMENT_OPTION, BAYEUX_VERSION, MAX_BACKOFF_OPTION

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Constructor and Description
SalesforceBayeuxClient(Config config, String serviceUrl, SalesforceLongPollingTransport transport) Create a new instance of this Bayeux client.

Method Summary

Modifier and Type	Method and Description
static Map<String,Object>	createDefaultLongPollingOptions()
void	handshake()
Boolean	isForceResubscribe()
void	onFailure(Throwable x, List<? extends org.cometd.bayeux.Message> messages) Callback method invoked when the given messages have failed to be sent.
static Map<String,Object>	replaceMissingMandatoryOptionsWithDefaults(Map<String,Object> result)
void	subscribe(String channel, org.cometd.bayeux.client.ClientSessionChannel.MessageListener messageListener)
void	unsubscribe()
void	unsubscribe(String channel)

Methods inherited from class org.cometd.client.BayeuxClient

abort, disconnect, disconnect, disconnect, enqueueSend, getAllowedTransports, getBackoff, getBackoffIncrement, getCookie, getCookieStore, getId, getKnownTransportNames, getMaxBackoff, getOption, getOptionNames, getOptions, getState, getTransport, getTransport, getURL, handshake, handshake, handshake, handshake, handshake, initialize, isConnected, isDisconnected, isHandshook, messagesFailure, newChannel, newChannelId, onMessages, onSending, onTransportFailure, onTransportFailure, processConnect, processDisconnect, processHandshake, processMessage, putCookie, scheduleConnect, scheduleHandshake, send, sendBatch, sendConnect, sendHandshake, sendMessages, setOption, terminate, waitFor

Methods inherited from class org.cometd.common.AbstractClientSession

addExtension, batch, dump, dump, endBatch, extendRcv, extendSend, getAttribute, getAttributeNames, getChannel, getChannel, getChannels, getExtensions, isBatching, newMessage, newMessageId, notifyListener, notifyListeners, receive, registerCallback, registerSubscriber, remoteCall, removeAttribute, removeExtension, resetSubscriptions, setAttribute, startBatch, unregisterCallback, unregisterSubscriber

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dumpObject, dumpObjects, dumpSelf

Constructor Detail

SalesforceBayeuxClient

public SalesforceBayeuxClient(Config config,
                              String serviceUrl,
                              SalesforceLongPollingTransport transport)
                       throws MalformedURLException

Create a new instance of this Bayeux client.

Parameters:

config - Salesforce connection

serviceUrl - - url to connect bayeux client to

transport - - transport for the communication with server

Throws:

MalformedURLException - when serviceUrl is not correct

Method Detail

isForceResubscribe

public Boolean isForceResubscribe()

createDefaultLongPollingOptions

public static Map<String,Object> createDefaultLongPollingOptions()

replaceMissingMandatoryOptionsWithDefaults

public static Map<String,Object> replaceMissingMandatoryOptionsWithDefaults(Map<String,Object> result)

onFailure

public void onFailure(Throwable x,
                      List<? extends org.cometd.bayeux.Message> messages)

Callback method invoked when the given messages have failed to be sent.

The default implementation logs the failure at INFO level.

Overrides:

onFailure in class org.cometd.client.BayeuxClient

Parameters:

x - the exception that caused the failure

messages - the messages being sent

handshake

public void handshake()

Specified by:

handshake in interface org.cometd.bayeux.client.ClientSession

Overrides:

handshake in class org.cometd.client.BayeuxClient

unsubscribe

public void unsubscribe()

unsubscribe

public void unsubscribe(String channel)

subscribe

public void subscribe(String channel,
                      org.cometd.bayeux.client.ClientSessionChannel.MessageListener messageListener)