MigratoryDataClient

This class implements all the necessary operations for connecting to a cluster of MigratoryData servers and publishing real-time messages.

Public Functions

Name
MigratoryDataClient()
Create a MigratoryDataClient object.
void setEntitlementToken(String token)
Assign an entitlement token to the client.
void setConnectionTimeout(long connectionTimeoutMs)
Define the timeout value to establish a connection with a MigratoryData server.
void setServers(List< String > servers)
Specify a cluster of one or more MigratoryData servers to which the client will connect to.
void setEncryption(boolean encrypted)
Configure whether to use SSL/TLS encryption when connecting to a MigratoryData server.
void connect()
Use this method to connect this client to one of the MigratoryData servers you specified with MigratoryDataClient.setServers().
String publish(MigratoryDataMessage message)
Publish the message provided in argument.
void disconnect()
Disconnect from the connected MigratoryData server and dispose the resources used by the connection.
void setTransport(String type)
Define the transport type used by the client to communicate with the MigratoryData cluster.

Public Attributes

Name
final String NOTIFY_PUBLISH_OK
A constant which indicates that the client successfully published a message.
final String NOTIFY_PUBLISH_FAILED
A constant which indicates that the client was unable to publish a message.
final String NOTIFY_MESSAGE_SIZE_LIMIT_EXCEEDED
A constant which indicates that the client was unable to publish a message because the size of the message exceeds the message size limit allowed by the server (see the server parameter MAX_MESSAGE_SIZE).
final String NOTIFY_PUBLISH_DENIED
A constant which indicates that the client was unable to publish a message because it is not allowed by the entitlement system.
final String TRANSPORT_HTTP
A constant used to define the transport type.
final String TRANSPORT_WEBSOCKET
A constant used to define the transport type.

Public Functions Documentation

function MigratoryDataClient

MigratoryDataClient()

Create a MigratoryDataClient object.

function setEntitlementToken

void setEntitlementToken(
    String token
)

Assign an entitlement token to the client.

Parameters:

  • token a string representing an entitlement token

Exceptions:

To define which users of your application have access to which subjects, you will first have to configure the parameter Entitlement, see the Configuration Guide. If you set this parameter on Custom, then you can use the MigratoryData Extension SDK for Entitlement to build an extension plugin for the MigratoryData server to allow or deny certain users to subscribe to or publish on certain subjects.

function setConnectionTimeout

void setConnectionTimeout(
    long connectionTimeoutMs
)

Define the timeout value to establish a connection with a MigratoryData server.

Parameters:

  • connectionTimeoutMs The timeout value (in milliseconds) used by the client to establish a connection with a MigratoryData server; default value is 1000 milliseconds.

Exceptions:

function setServers

void setServers(
    List< String > servers
)

Specify a cluster of one or more MigratoryData servers to which the client will connect to.

Parameters:

  • servers The addresses of the MigratoryData servers in the cluster.

Exceptions:

function setEncryption

void setEncryption(
    boolean encrypted
)

Configure whether to use SSL/TLS encryption when connecting to a MigratoryData server.

Parameters:

  • encrypted indicate whether or not to use an encrypted SSL/TLS connection to communicate with the server

When using encryption you should connect to the ports of the MigratoryData server that are configured with the parameter ListenEncrypted to listen for encrypted connections. Make sure that the php_openssl extension is enabled (usually need to be manually enabled on Windows OS).

function connect

void connect()

Use this method to connect this client to one of the MigratoryData servers you specified with MigratoryDataClient.setServers().

Exceptions:

  • MigratoryDataException Exceptions with the following error codes:

  • E_RUNNING

  • E_INVALID_URL_LIST

  • E_CLUSTER_MEMBERS_CONNECTION_FAILED

  • E_ENTITLEMENT_TOKEN

function publish

String publish(
    MigratoryDataMessage message
)

Publish the message provided in argument.

Parameters:

Exceptions:

  • MigratoryDataException Exceptions with the following error codes:

  • E_NOT_CONNECTED

  • E_MSG_NULL

  • E_MSG_INVALID

  • E_INVALID_SUBJECT

  • E_INVALID_PROTOCOL

Return: A string representing the response received from the MigratoryData cluster:

  • NOTIFY_PUBLISH_OK,
  • NOTIFY_PUBLISH_FAILED, or
  • NOTIFY_PUBLISH_DENIED

function disconnect

void disconnect()

Disconnect from the connected MigratoryData server and dispose the resources used by the connection.

This method should be called when the connection is no longer necessary.

function setTransport

void setTransport(
    String type
)

Define the transport type used by the client to communicate with the MigratoryData cluster.

Parameters:

Public Attributes Documentation

variable NOTIFY_PUBLISH_OK

static final String NOTIFY_PUBLISH_OK = "NOTIFY_PUBLISH_OK";

A constant which indicates that the client successfully published a message.

variable NOTIFY_PUBLISH_FAILED

static final String NOTIFY_PUBLISH_FAILED = "NOTIFY_PUBLISH_FAILED";

A constant which indicates that the client was unable to publish a message.

variable NOTIFY_MESSAGE_SIZE_LIMIT_EXCEEDED

static final String NOTIFY_MESSAGE_SIZE_LIMIT_EXCEEDED = "NOTIFY_MESSAGE_SIZE_LIMIT_EXCEEDED";

A constant which indicates that the client was unable to publish a message because the size of the message exceeds the message size limit allowed by the server (see the server parameter MAX_MESSAGE_SIZE).

variable NOTIFY_PUBLISH_DENIED

static final String NOTIFY_PUBLISH_DENIED = "NOTIFY_PUBLISH_DENIED";

A constant which indicates that the client was unable to publish a message because it is not allowed by the entitlement system.

variable TRANSPORT_HTTP

static final String TRANSPORT_HTTP = "TRANSPORT_HTTP";

A constant used to define the transport type.

See MigratoryDataClient.setTransport() for more details about this policy.

variable TRANSPORT_WEBSOCKET

static final String TRANSPORT_WEBSOCKET = "TRANSPORT_WEBSOCKET";

A constant used to define the transport type.

See MigratoryDataClient.setTransport() for more details about this policy.


Updated on 6 November 2020 at 13:20:01 EET