Implements a data portal proxy to relay data portal calls to a remote application server by using RabbitMQ. More...

Inheritance diagram for Csla.Channels.RabbitMq.RabbitMqProxy:

Public Member Functions
	RabbitMqProxy ()
	Creates an instance of the object, initializing it to use the DefaultUrl value. More...

	RabbitMqProxy (string dataPortalUrl)
	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...

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
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 = ApplicationContext.DataPortalUrlString `[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...

Detailed Description

Implements a data portal proxy to relay data portal calls to a remote application server by using RabbitMQ.

Definition at line 24 of file RabbitMqProxy.cs.

Constructor & Destructor Documentation

◆ RabbitMqProxy() [1/2]

Csla.Channels.RabbitMq.RabbitMqProxy.RabbitMqProxy ( )

Creates an instance of the object, initializing it to use the DefaultUrl value.

Definition at line 30 of file RabbitMqProxy.cs.

◆ RabbitMqProxy() [2/2]

Csla.Channels.RabbitMq.RabbitMqProxy.RabbitMqProxy ( string dataPortalUrl )

Creates an instance of the object, initializing it to use the supplied URL.

Parameters

dataPortalUrl RabbitMQ service URL

Definition at line 39 of file RabbitMqProxy.cs.

Member Function Documentation

◆ CallDataPortalServer()

override async Task< byte[]> Csla.Channels.RabbitMq.RabbitMqProxy.CallDataPortalServer	(	byte[]	serialized,
		string	operation,
		string	routingToken,
		bool	isSync
	)

protectedvirtual

Create message and send to Rabbit MQ server.

Return Response from server

Parameters

serialized	Serialised request
operation	DataPortal operation
routingToken	Routing Tag for server
isSync	True if the client-side proxy should synchronously invoke the server.

Returns: Serialised response from server

Implements Csla.DataPortalClient.DataPortalProxy.

Definition at line 191 of file RabbitMqProxy.cs.

◆ Create()

override async Task< DataPortalResult > Csla.Channels.RabbitMq.RabbitMqProxy.Create	(	Type	objectType,
		object	criteria,
		DataPortalContext	context,
		bool	isSync
	)

virtual

Called by DataPortal to create a new business object.

Parameters

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 117 of file RabbitMqProxy.cs.

◆ Delete()

override async Task< DataPortalResult > Csla.Channels.RabbitMq.RabbitMqProxy.Delete	(	Type	objectType,
		object	criteria,
		DataPortalContext	context,
		bool	isSync
	)

virtual

Called by DataPortal to delete a business object.

Parameters

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 173 of file RabbitMqProxy.cs.

◆ Dispose()

void Csla.Channels.RabbitMq.RabbitMqProxy.Dispose ( )

Dispose this object and its resources.

Definition at line 223 of file RabbitMqProxy.cs.

◆ Fetch()

override async Task< DataPortalResult > Csla.Channels.RabbitMq.RabbitMqProxy.Fetch	(	Type	objectType,
		object	criteria,
		DataPortalContext	context,
		bool	isSync
	)

virtual

Called by DataPortal to load an existing business object.

Parameters

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 136 of file RabbitMqProxy.cs.

◆ InitializeRabbitMQ()

virtual void Csla.Channels.RabbitMq.RabbitMqProxy.InitializeRabbitMQ ( )

protectedvirtual

Method responsible for creating the Connection, Channel, ReplyQueue, and DataPortalQueueName values used for bi-directional communication.

Definition at line 77 of file RabbitMqProxy.cs.

◆ Update()

override async Task< DataPortalResult > Csla.Channels.RabbitMq.RabbitMqProxy.Update	(	object	obj,
		DataPortalContext	context,
		bool	isSync
	)

virtual

Called by DataPortal to update a business object.

Parameters

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 154 of file RabbitMqProxy.cs.

Property Documentation

◆ Channel

IModel Csla.Channels.RabbitMq.RabbitMqProxy.Channel

getsetprotected

Gets or sets the channel (model) for RabbitMQ.

Definition at line 58 of file RabbitMqProxy.cs.

◆ Connection

IConnection Csla.Channels.RabbitMq.RabbitMqProxy.Connection

getsetprotected

Gets or sets the connection to the RabbitMQ service.

Definition at line 53 of file RabbitMqProxy.cs.

◆ DataPortalQueueName

string Csla.Channels.RabbitMq.RabbitMqProxy.DataPortalQueueName

getsetprotected

Gets or sets the name of the data portal service queue.

Definition at line 64 of file RabbitMqProxy.cs.

◆ Timeout

override int Csla.Channels.RabbitMq.RabbitMqProxy.Timeout = 30

getset

Gets or sets the timeout for network operations in seconds (default is 30 seconds).

Definition at line 48 of file RabbitMqProxy.cs.

Public Member Functions

Protected Member Functions

Properties

Detailed Description

Constructor & Destructor Documentation

◆ RabbitMqProxy() [1/2]

◆ RabbitMqProxy() [2/2]

Member Function Documentation

◆ CallDataPortalServer()

◆ Create()

◆ Delete()

◆ Dispose()

◆ Fetch()

◆ InitializeRabbitMQ()

◆ Update()

Property Documentation

◆ Channel

◆ Connection

◆ DataPortalQueueName

◆ Timeout