Click or drag to resize

AmqpCFXEndpoint Methods

The AmqpCFXEndpoint type exposes the following members.

Methods
 NameDescription
Public methodAddListener Allows this endpoint to listen for and receive unsolicited (published) messages directly from multiple CFX endpoints that have been configured to publish messages to this endpoint, just like a message broker. Your endpoint must be configured to receive requests (via the Open method requestUri parameter) before adding a listener.
Public methodAddMessageSource Set up a message source on this endpoint that other endpoints may subscribe to. Messages published to a message source are placed in a queue, and remain there until a subscriber connects and removes them. The queue is volatile, and will be deleted when the hosting process is restarted.
Public methodAddPublishChannel(AmqpChannelAddress, String, X509Certificate) Adds a new publish channel for this endpoint. All messages published by the endpoint will be transmitted to one or more publish channels that are established using this method. Only call this methoud after this endpoint has been opened by the Open method.
Public methodAddPublishChannel(Uri, String, String, X509Certificate) Adds a new publish channel for this endpoint. All messages published by the endpoint will be transmitted to one or more publish channels that are established using this method. Only call this methoud after this endpoint has been opened by the Open method.
Public methodAddSubscribeChannel(AmqpChannelAddress, String, X509Certificate) Adds a new subscription channel for this endpoint.
Public methodAddSubscribeChannel(Uri, String, String, X509Certificate) Adds a new subscription channel for this endpoint.
Public methodClose Closes the endpoint, including all inbound and outbound channels.
Public methodCloseListener Closes a previously added listener (added with AddListener method).
Public methodCloseMessageSource Closes a previously added message source. All messages in the source's queue will be purged upon closing.
Public methodClosePublishChannel(AmqpChannelAddress) Closes the specified publish channel (that was opened previously via a call to AddPublishChannel.
Public methodClosePublishChannel(Uri, String) Closes the specified publish channel (that was opened previously via a call to AddPublishChannel.
Public methodCloseSubscribeChannel(AmqpChannelAddress) Closes the specified subscription channel (that was opened previously via a call to AddSubscribeChannel.
Public methodCloseSubscribeChannel(Uri, String) Closes the specified subscription channel (that was opened previously via a call to AddSubscribeChannel.
Public methodDispose Disposes the endpoint, closing all inbound and outbound channels.
Public methodExecuteRequest Performs a direct, point-to-point request/response transaction with another CFX Endpoint.
Public methodExecuteRequestAsync Performs a direct, point-to-point request/response transaction with another CFX Endpoint.
Public methodGetSpoolSize Returns the total number of messages spooled for a particular
Public methodOpen(String, Uri, X509Certificate2) Opens and inintializes the Endpoint. This should be called only once prior to closing the endpoint.
Public methodOpen(String, IPAddress, Int32, X509Certificate2) Opens and inintializes the Endpoint. This should be called only once prior to closing the endpoint.
Public methodPublish(CFXEnvelope) Publishes a CFX message. The message will be transmitted to all publish channels.
Public methodPublish(CFXMessage) Publishes a CFX message. A CFX envelope will be automatically generated for your message. The message will be transmitted to all publish channels.
Public methodPublishMany(IEnumerableCFXEnvelope) Publishes multiple CFX messages at one time. The messages will be transmitted to all publish channels.
Public methodPublishMany(IEnumerableCFXMessage) Publishes multiple CFX messages at one time. CFX envelopes will be automatically generated for your messages. The messages will be transmitted to all publish channels.
Public methodPublishManyToChannel(IEnumerableCFXEnvelope, AmqpChannelAddress) Publishes a collection of CFX envelopes to the specified channel.
Public methodPublishManyToChannel(IEnumerableCFXMessage, AmqpChannelAddress) Publishes a collection of CFX messages to the specified channel. CFX envelopes will be automatically generated for each of your messages.
Public methodPublishManyToMessageSource Publishes multiple messages to a message source.
Public methodPublishToChannel(CFXEnvelope, AmqpChannelAddress) Publishes a CFX envelope to the specified channel.
Public methodPublishToChannel(CFXMessage, AmqpChannelAddress) Publishes a CFX message to the specified channel. A CFX envelope will be automatically generated for your message.
Public methodPublishToMessageSource Publishes a single message to a message source.
Public methodPurgeAllSpools Permanently deletes all spooled messages from all Publish channels associated with this endpoint.
Public methodPurgeMessageSource Purges all queued messages for the given message source.
Public methodPurgeSpool Permanently deletes all spooled messages from the specified Publish channel.
Public methodTestChannel Tests if the specified network address is capable of establishing an AMQP connection from this endpoint.
Public methodTestPublishChannel Tests if the specified network address and AMQP target address is capable of receiving messages published from this endpoint.
Public methodTestSubscribeChannel Tests if this endpoint is capable of subscribing to and receiving message from the specified network address and AMQP source address.
Top
See Also