summaryrefslogtreecommitdiff
path: root/vb/demo/IceStorm/clock/Subscriber.vb
diff options
context:
space:
mode:
Diffstat (limited to 'vb/demo/IceStorm/clock/Subscriber.vb')
-rwxr-xr-xvb/demo/IceStorm/clock/Subscriber.vb74
1 files changed, 37 insertions, 37 deletions
diff --git a/vb/demo/IceStorm/clock/Subscriber.vb b/vb/demo/IceStorm/clock/Subscriber.vb
index b691d50793d..1ea97093286 100755
--- a/vb/demo/IceStorm/clock/Subscriber.vb
+++ b/vb/demo/IceStorm/clock/Subscriber.vb
@@ -26,43 +26,43 @@ Module ClockS
Inherits Ice.Application
Public Overloads Overrides Function run(ByVal args() As String) As Integer
- Dim basePrx As Ice.ObjectPrx = communicator().propertyToProxy("IceStorm.TopicManager.Proxy")
- Dim manager As IceStorm.TopicManagerPrx = IceStorm.TopicManagerPrxHelper.checkedCast(basePrx)
- If manager Is Nothing Then
- Console.Error.WriteLine("invalid proxy")
- Return 1
- End If
-
- Dim topicName As String = "time"
- If not args.Length = 0 Then:
- topicName = args(0)
- End If
-
- Dim topic As IceStorm.TopicPrx
- Try
- topic = manager.retrieve(topicName)
- Catch ex As IceStorm.NoSuchTopic
- Try
- topic = manager.create(topicName)
- Catch e As IceStorm.TopicExists
- Console.Error.WriteLine("temporary error. try again.")
- Return 1
- End Try
- End Try
-
- Dim adapter As Ice.ObjectAdapter = communicator().createObjectAdapter("Clock.Subscriber")
-
- Dim subscriber As Ice.ObjectPrx = adapter.addWithUUID(New ClockI)
-
- Dim qos As IceStorm.Qos = New IceStorm.Qos
-
- topic.subscribe(qos, subscriber)
- adapter.activate()
-
- shutdownOnInterrupt()
- communicator().waitForShutdown()
-
- topic.unsubscribe(subscriber)
+ Dim basePrx As Ice.ObjectPrx = communicator().propertyToProxy("IceStorm.TopicManager.Proxy")
+ Dim manager As IceStorm.TopicManagerPrx = IceStorm.TopicManagerPrxHelper.checkedCast(basePrx)
+ If manager Is Nothing Then
+ Console.Error.WriteLine("invalid proxy")
+ Return 1
+ End If
+
+ Dim topicName As String = "time"
+ If not args.Length = 0 Then:
+ topicName = args(0)
+ End If
+
+ Dim topic As IceStorm.TopicPrx
+ Try
+ topic = manager.retrieve(topicName)
+ Catch ex As IceStorm.NoSuchTopic
+ Try
+ topic = manager.create(topicName)
+ Catch e As IceStorm.TopicExists
+ Console.Error.WriteLine("temporary error. try again.")
+ Return 1
+ End Try
+ End Try
+
+ Dim adapter As Ice.ObjectAdapter = communicator().createObjectAdapter("Clock.Subscriber")
+
+ Dim subscriber As Ice.ObjectPrx = adapter.addWithUUID(New ClockI)
+
+ Dim qos As IceStorm.Qos = New IceStorm.Qos
+
+ topic.subscribe(qos, subscriber)
+ adapter.activate()
+
+ shutdownOnInterrupt()
+ communicator().waitForShutdown()
+
+ topic.unsubscribe(subscriber)
Return 0
End Function