-
Notifications
You must be signed in to change notification settings - Fork 3.6k
/
ViewController.swift
41 lines (36 loc) · 1.13 KB
/
ViewController.swift
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
//
// ViewController.swift
// tutorial1
//
// Copyright © 2016 RabbitMQ. All rights reserved.
//
import UIKit
import RMQClient
class ViewController: UIViewController {
override func viewDidLoad() {
super.viewDidLoad()
self.send()
self.receive()
}
func send() {
print("Attempting to connect to local RabbitMQ broker")
let conn = RMQConnection(delegate: RMQConnectionDelegateLogger())
conn.start()
let ch = conn.createChannel()
let q = ch.queue("hello")
ch.defaultExchange().publish("Hello World!".data(using: .utf8), routingKey: q.name)
print("Sent 'Hello World!'")
conn.close()
}
func receive() {
print("Attempting to connect to local RabbitMQ broker")
let conn = RMQConnection(delegate: RMQConnectionDelegateLogger())
conn.start()
let ch = conn.createChannel()
let q = ch.queue("hello")
print("Waiting for messages.")
q.subscribe({(_ message: RMQMessage) -> Void in
print("Received \(String(data: message.body, encoding: String.Encoding.utf8)!)")
})
}
}