Implements a data portal proxy to relay data portal calls to a remote application server by using RabbitMQ. More...
Public Member Functions | |
RabbitMqProxy (ApplicationContext applicationContext, RabbitMqProxyOptions options) | |
Creates an instance of the object, initializing it to use the supplied URL. More... | |
override async Task< DataPortalResult > | Create (Type objectType, object criteria, DataPortalContext context, bool isSync) |
Called by DataPortal to create a new business object. More... | |
override async Task< DataPortalResult > | Fetch (Type objectType, object criteria, DataPortalContext context, bool isSync) |
Called by DataPortal to load an existing business object. More... | |
override async Task< DataPortalResult > | Update (object obj, DataPortalContext context, bool isSync) |
Called by DataPortal to update a business object. More... | |
override async Task< DataPortalResult > | Delete (Type objectType, object criteria, DataPortalContext context, bool isSync) |
Called by DataPortal to delete a business object. More... | |
void | Dispose () |
Dispose this object and its resources. More... | |
Public Member Functions inherited from Csla.DataPortalClient.DataPortalProxy | |
DataPortalProxy (ApplicationContext applicationContext) | |
Protected Member Functions | |
virtual void | InitializeRabbitMQ () |
Method responsible for creating the Connection, Channel, ReplyQueue, and DataPortalQueueName values used for bi-directional communication. More... | |
override async Task< byte[]> | CallDataPortalServer (byte[] serialized, string operation, string routingToken, bool isSync) |
Create message and send to Rabbit MQ server. More... | |
Protected Member Functions inherited from Csla.DataPortalClient.DataPortalProxy | |
virtual CriteriaRequest | ConvertRequest (CriteriaRequest request) |
Override this method to manipulate the message request data sent to the server. More... | |
virtual UpdateRequest | ConvertRequest (UpdateRequest request) |
Override this method to manipulate the message request data sent to the server. More... | |
virtual DataPortalResponse | ConvertResponse (DataPortalResponse response) |
Override this method to manipulate the message request data returned from the server. More... | |
Properties | |
override int | Timeout = 30 [getset] |
Gets or sets the timeout for network operations in seconds (default is 30 seconds). More... | |
IConnection | Connection [getset] |
Gets or sets the connection to the RabbitMQ service. More... | |
IModel | Channel [getset] |
Gets or sets the channel (model) for RabbitMQ. More... | |
string | DataPortalQueueName [getset] |
Gets or sets the name of the data portal service queue. More... | |
Properties inherited from Csla.DataPortalClient.DataPortalProxy | |
ApplicationContext | ApplicationContext [getset] |
Gets or sets the current ApplicationContext object. More... | |
virtual bool | IsServerRemote [get] |
Gets a value indicating whether the data portal is hosted on a remote server. More... | |
virtual int | Timeout [getset] |
Gets or sets the Client timeout in milliseconds (0 uses default timeout). More... | |
string | DataPortalUrl [getprotected set] |
Gets the URL address for the data portal server used by this proxy instance. More... | |
Properties inherited from Csla.DataPortalClient.IDataPortalProxy | |
bool | IsServerRemote [get] |
Get a value indicating whether this proxy will invoke a remote data portal server, or run the "server-side" data portal in the caller's process and AppDomain. More... | |
Implements a data portal proxy to relay data portal calls to a remote application server by using RabbitMQ.
Definition at line 20 of file RabbitMqProxy.cs.
Csla.Channels.RabbitMq.RabbitMqProxy.RabbitMqProxy | ( | ApplicationContext | applicationContext, |
RabbitMqProxyOptions | options | ||
) |
Creates an instance of the object, initializing it to use the supplied URL.
applicationContext | |
options | Proxy options |
Definition at line 28 of file RabbitMqProxy.cs.
|
protectedvirtual |
Create message and send to Rabbit MQ server.
Return Response from server
serialized | Serialised request |
operation | DataPortal operation |
routingToken | Routing Tag for server |
isSync | True if the client-side proxy should synchronously invoke the server. |
Implements Csla.DataPortalClient.DataPortalProxy.
Definition at line 181 of file RabbitMqProxy.cs.
|
virtual |
Called by DataPortal to create a new business object.
objectType | Type of business object to create. |
criteria | Criteria object describing business object. |
context | DataPortalContext object passed to the server. |
isSync | True if the client-side proxy should synchronously invoke the server. |
Reimplemented from Csla.DataPortalClient.DataPortalProxy.
Definition at line 107 of file RabbitMqProxy.cs.
|
virtual |
Called by DataPortal to delete a business object.
objectType | Type of business object to create. |
criteria | Criteria object describing business object. |
context | Server.DataPortalContext object passed to the server. |
isSync | True if the client-side proxy should synchronously invoke the server. |
Reimplemented from Csla.DataPortalClient.DataPortalProxy.
Definition at line 163 of file RabbitMqProxy.cs.
void Csla.Channels.RabbitMq.RabbitMqProxy.Dispose | ( | ) |
Dispose this object and its resources.
Definition at line 213 of file RabbitMqProxy.cs.
|
virtual |
Called by DataPortal to load an existing business object.
objectType | Type of business object to create. |
criteria | Criteria object describing business object. |
context | Server.DataPortalContext object passed to the server. |
isSync | True if the client-side proxy should synchronously invoke the server. |
Reimplemented from Csla.DataPortalClient.DataPortalProxy.
Definition at line 126 of file RabbitMqProxy.cs.
|
protectedvirtual |
Method responsible for creating the Connection, Channel, ReplyQueue, and DataPortalQueueName values used for bi-directional communication.
Definition at line 67 of file RabbitMqProxy.cs.
|
virtual |
Called by DataPortal to update a business object.
obj | The business object to update. |
context | Server.DataPortalContext object passed to the server. |
isSync | True if the client-side proxy should synchronously invoke the server. |
Reimplemented from Csla.DataPortalClient.DataPortalProxy.
Definition at line 144 of file RabbitMqProxy.cs.
|
getsetprotected |
Gets or sets the channel (model) for RabbitMQ.
Definition at line 48 of file RabbitMqProxy.cs.
|
getsetprotected |
Gets or sets the connection to the RabbitMQ service.
Definition at line 43 of file RabbitMqProxy.cs.
|
getsetprotected |
Gets or sets the name of the data portal service queue.
Definition at line 54 of file RabbitMqProxy.cs.
|
getset |
Gets or sets the timeout for network operations in seconds (default is 30 seconds).
Definition at line 38 of file RabbitMqProxy.cs.