org.wso2.carbon.inbound.salesforce.poll

Class SalesforceStreamData

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer

org.wso2.carbon.inbound.salesforce.poll.SalesforceStreamData

All Implemented Interfaces:

ConnectionFailureListener

public class SalesforceStreamData
extends org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer
implements ConnectionFailureListener

Salesforce streaming api Inbound.

Field Summary

Fields inherited from class org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer

coordination, name, onErrorSeq, properties, scanInterval, sequential, synapseEnvironment

Constructor Summary

Constructors

Constructor and Description
SalesforceStreamData(Properties salesforceProperties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, long scanInterval, String injectingSeq, String onErrorSeq, boolean coordination, boolean sequential)

Method Summary

Modifier and Type	Method and Description
void	destroy() stop the connector when redeploy or shutdown the server.
void	onConnectionFailure() Handles connection failure notifications from the EmpConnector.
Object	poll() Each polling time this method calls
void	resume()

Methods inherited from class org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer

getInboundProperties, injectMessage, injectMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

SalesforceStreamData

public SalesforceStreamData(Properties salesforceProperties,
                            String name,
                            org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
                            long scanInterval,
                            String injectingSeq,
                            String onErrorSeq,
                            boolean coordination,
                            boolean sequential)

Method Detail

onConnectionFailure

public void onConnectionFailure()

Handles connection failure notifications from the EmpConnector. Sets the connectionFailed flag to true when a failure is detected.

Specified by:

onConnectionFailure in interface ConnectionFailureListener

poll

public Object poll()

Each polling time this method calls

Specified by:

poll in class org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer

Returns:

destroy

public void destroy()

stop the connector when redeploy or shutdown the server.

Overrides:

destroy in class org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer

resume

public void resume()

Overrides:

resume in class org.wso2.carbon.inbound.endpoint.protocol.generic.GenericPollingConsumer