TECHNOLOGIES
FORUMS
JOBS
BOOKS
EVENTS
INTERVIEWS
Live
MORE
LEARN
Training
CAREER
MEMBERS
VIDEOS
NEWS
BLOGS
Sign Up
Login
No unread comment.
View All Comments
No unread message.
View All Messages
No unread notification.
View All Notifications
Answers
Post
An Article
A Blog
A News
A Video
An EBook
An Interview Question
Ask Question
Forums
Monthly Leaders
Forum guidelines
Guest User
Tech Writer
2.1k
482.1k
System.Net.Socket Error using Azure-Iot-device-read-message
Aug 29 2019 4:28 AM
Hi team
I have this error on my console application;
using
System;
using
System.Threading;
using
System.Collections.Generic;
using
System.Linq;
using
System.Text;
using
System.Threading.Tasks;
using
Microsoft.Azure.EventHubs;
namespace
ReadMessageApplication
{
class
Program
{
private
readonly
static
string
s_eventHubsCompartibleEndpoint =
"sb://iothub-ns-university-2081416-42bc501981.servicebus.windows.net/"
;
private
readonly
static
string
s_eventHubsCompartiblePath =
"universityiothub"
;
private
readonly
static
string
s_iotHubSasKey =
"****="
;
private
readonly
static
string
s_iotHubSasKeyName =
"iothubowner"
;
private
static
EventHubClient s_eventhubClient;
private
static
async Task ReceivedMessageFromDeviceAsync(
string
partition, CancellationToken ct)
{
var eventHubReciver = s_eventhubClient.CreateReceiver(
"$Default"
, partition, EventPosition.FromEnqueuedTime(DateTime.Now));
Console.WriteLine(
"Create receiver on partition:"
+ partition);
while
(
true
)
{
if
(ct.IsCancellationRequested)
break
;
Console.WriteLine(
"Listening for messages on:"
+ partition);
var events = await eventHubReciver.ReceiveAsync(100);
if
(events ==
null
)
continue
;
foreach
(EventData eventData
in
events)
{
string
data = Encoding.UTF8.GetString(eventData.Body.Array);
Console.WriteLine(
"Message received on partition {0}:"
, partition);
Console.WriteLine(
" {0}:"
, data);
Console.WriteLine(
"Application properties (set by device)"
);
foreach
(var prop
in
eventData.Properties)
{
Console.WriteLine(
" {0}: {1}"
, prop.Key, prop.Value);
}
Console.WriteLine(
"System properties (set by Iot Hub)"
);
foreach
(var prop
in
eventData.SystemProperties)
{
Console.WriteLine(
" {0}: {1}"
, prop.Key, prop.Value);
}
}
}
}
private
static
async Task Main(
string
[] args)
{
Console.WriteLine(
"IOT Hub Device Message - Read device to cloud message. Ctrl-C to exit.\n"
);
var connectionString =
new
EventHubsConnectionStringBuilder(
new
Uri(s_eventHubsCompartibleEndpoint), s_eventHubsCompartiblePath, s_iotHubSasKeyName, s_iotHubSasKey);
s_eventhubClient = EventHubClient.CreateFromConnectionString(connectionString.ToString());
//partition receiver for each hub.
var runtimeInfo = await s_eventhubClient.GetRuntimeInformationAsync();
var dtwoPartition = runtimeInfo.PartitionIds;
CancellationTokenSource ct =
new
CancellationTokenSource();
Console.CancelKeyPress += (s, e) =>
{
e.Cancel =
true
;
ct.Cancel();
Console.WriteLine(
"Exiting.."
);
};
var tasks =
new
List<Task>();
foreach
(
string
partition
in
dtwoPartition)
{
tasks.Add(ReceivedMessageFromDeviceAsync(partition, ct.Token));
}
Task.WaitAll(tasks.ToArray());
}
}
}
Reply
Answers (
2
)
Incorrect syntax near ‘SET’ in asp.net c#
A simple loop when editing