diff options
Diffstat (limited to 'vb/demo/IceStorm/clock/Subscriber.vb')
-rwxr-xr-x | vb/demo/IceStorm/clock/Subscriber.vb | 74 |
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 |