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();
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