please , How can I implement automatic queue binding to an exchange? with swift #227

didtlrhks · 2024-01-30T18:02:34Z

didtlrhks
Jan 30, 2024

import UIKit

import RMQClient

class ViewController: UIViewController {


    override func viewDidLoad() {
        super.viewDidLoad()
        self.receiveLogs()
        self.receiveLogs()
        sleep(1)
        self.emitLog()
    }
        func createConnection() -> RMQConnection {
//            let hostName = "112.219.138.170" // 호스트명
//            let userName = "neo" // 유저 이름
//            let password = "01579" // 비밀번호
//            let virtualHost = "/" // 가상 호스트 (기본값인 "/"를 사용하려면 변경하지 마세요)
    
//            let uri = "amqp://\(userName):\(password)@\(hostName):5672\(virtualHost)"
//        http://username:password@yoursitename.com
            let uri = "amqp://neo:01579@secure:5672"
            let delegate = RMQConnectionDelegateLogger()
            let connection = RMQConnection(uri:uri,delegate: delegate)
            return connection
        }
    
    func emitLog() {
        
        let conn = createConnection()
        conn.start()
        let ch = conn.createChannel()
        let x = ch.fanout("logs")
        let msg = "Hello World!"
        let q = ch.queue("neotest")
        ch.defaultExchange().publish(msg.data(using: .utf8)!,routingKey: q.name)
        
        
//        x.publish(msg.data(using: String.Encoding.utf8)!)
        print("Sent \(msg)")
       // conn.close()
    }

    func receiveLogs() {
        let conn = createConnection()
        conn.start()
        let ch = conn.createChannel()
        
        let x = ch.fanout("logs")
        let q = ch.queue("neotest")
        q.bind(x)
        print("Waiting for logs.")
        
        q.subscribe({(_ message: RMQMessage) -> Void in
            print("Received \(String(data: message.body, encoding: String.Encoding.utf8)!)")
        })
        
//                q.subscribe({(_ message: RMQMessage) -> Void in
//                    if let messageString = String(data: message.body, encoding: .utf8) {
//                        print("Received \(messageString)")
//        
//                    }
//                })
    }
}

here is my code how to automatic queue binding to an exchange?

michaelklishin · 2024-01-30T18:27:45Z

michaelklishin
Jan 30, 2024
Maintainer

@didtlrhks you keep ignoring our requests to

Not use issues for questions
Not use this repo, which has nothing to do with Swift (and your questions do not have anything to do with .NET)

I'm afraid we have no choice but to prevent you from filing new issues in this org.

0 replies

michaelklishin · 2024-01-30T18:31:23Z

michaelklishin
Jan 30, 2024
Maintainer

I don't know what "automatic" means when it comes to bindings, this integration test suite demonstrates how to bind a queue to an exchange using the Objective-C client from Swift.

0 replies

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

please , How can I implement automatic queue binding to an exchange? with swift #227

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Replies: 0 comments 2 replies

Uh oh!

{{title}}

Uh oh!

Uh oh!

{{editor}}'s edit

{{editor}}'s edit

Uh oh!

Uh oh!

{{title}}

Uh oh!

Select a reply

Uh oh!

please , How can I implement automatic queue binding to an exchange? with swift #227

Uh oh!

Uh oh!

didtlrhks Jan 30, 2024

Replies: 0 comments · 2 replies

Uh oh!

Uh oh!

michaelklishin Jan 30, 2024 Maintainer

Uh oh!

michaelklishin Jan 30, 2024 Maintainer

didtlrhks
Jan 30, 2024

Replies: 0 comments 2 replies

michaelklishin
Jan 30, 2024
Maintainer

michaelklishin
Jan 30, 2024
Maintainer