Thursday, 8 October 2015

Service Bus

A service namespace provides a scoping container for addressing Service bus resources within your
application.

1.it is useful to communicate decoupled applications

Note :Microsoft azure service bus install from nugetpackage

namespace : microsoft.ServiceBus

NamespaceManager class can be used to manage messaging entities in the service bus.

creation of queue :
===================
String strcon = ConfigurationManager.Appsettings["Microsoft.ServiceBus.ConnectionString"].tostring();

NamespaceManager nsMgr=NamespaceManager.CreateFromConnectionString(strcon);

if(nsMgr.QueueExists("TestQueue123"))
{
 nsMgr.DeleteQueue("TestQueue123");
}
else
{
 nsMgr.CreateQueue("TestQueue123");
}
add message to queue  and send:
==================
String strcon = ConfigurationManager.Appsettings["Microsoft.ServiceBus.ConnectionString"].tostring();

QueueClient qclint=QueueClient.CreateFromConnectionString(strcon,"TestQueue123");
BrokeredMessage message=new BorkeredMessage("My message to queue123");
qclient.send(message);

Receive Message :
================
BrokeredMessage message=null;
String strcon = ConfigurationManager.Appsettings["Microsoft.ServiceBus.ConnectionString"].tostring();

QueueClient qclint = QueueClient.CreateFromConnectionString(strcon,"TestQueue123");
 message= qclint.Receive(TimeSpan.FromSeconds(5));
if(message!=null)
{
message.complete();
}

qclient.close();


No comments:

Post a Comment