Class: Magicbroker::Client
- Inherits:
-
Object
- Object
- Magicbroker::Client
- Defined in:
- lib/client/client.rb
Instance Attribute Summary collapse
-
#server ⇒ Object
Returns the value of attribute server.
Instance Method Summary collapse
-
#initialize(server, clientID, topic) ⇒ Client
constructor
A new instance of Client.
- #receive_events(t) ⇒ Object
- #send_events(hash) ⇒ Object
- #subscribe ⇒ Object
- #unsubscribe ⇒ Object
Constructor Details
#initialize(server, clientID, topic) ⇒ Client
Returns a new instance of Client.
10 11 12 13 14 |
# File 'lib/client/client.rb', line 10 def initialize (server, clientID, topic) @server = server @clientID = clientID @topic = topic end |
Instance Attribute Details
#server ⇒ Object
Returns the value of attribute server.
8 9 10 |
# File 'lib/client/client.rb', line 8 def server @server end |
Instance Method Details
#receive_events(t) ⇒ Object
33 34 35 36 37 38 39 |
# File 'lib/client/client.rb', line 33 def receive_events(t) t.nil? ? t=1 : t=t print servlet = 'http://'+@server+'/event?clientID='+@clientID+'&topic='+@topic+'&timeOut='+t.to_s() Net::HTTP.get_print URI.parse(servlet) print servlet end |
#send_events(hash) ⇒ Object
26 27 28 29 30 31 |
# File 'lib/client/client.rb', line 26 def send_events(hash) print servlet = 'http://'+@server+'/event?clientID='+@clientID+'&topic='+@topic+'&_method=POST&'+hash.to_query Net::HTTP.get_print URI.parse(servlet) print servlet end |
#subscribe ⇒ Object
16 17 18 19 |
# File 'lib/client/client.rb', line 16 def subscribe () servlet = 'http://'+@server+'/subscribe?clientID='+@clientID+'&topic='+@topic Net::HTTP.get URI.parse(servlet) end |
#unsubscribe ⇒ Object
21 22 23 24 |
# File 'lib/client/client.rb', line 21 def unsubscribe () servlet = 'http://'+@server+'/unsubscribe?clientID='+@clientID+'&topic='+@topic Net::HTTP.get URI.parse(servlet) end |