StompClientLib

Introduction

StompClientLib is a stomp client in Swift. It uses Facebook's SocketRocket as a websocket dependency. SocketRocket is written in Objective-C but StompClientLib's STOMP part is written in Swift and its usage is Swift. You can use this library in your Swift 5+, 4+ and 3+ projects.

Supported Stomp Versions

Stomp version

1.1
1.2
Might not be worked with 1.0 (Never tested)

Example

To run the example project, clone the repo, and run pod install from the Example directory first.

Requirements

iOS 8.0+
XCode 8.1, 8.2, 8.3
XCode 9.0+
XCode 10.0 +
XCode 12.1 +
Swift 3.0, 3.1, 3.2
Swift 4.0, Swift 4.1, Swift 4.2, Swift 5.0

Installation

StompClientLib is available through CocoaPods. To install it, simply add the following line to your Podfile:

Cocoapods

pod "StompClientLib"

Carthage

github "WrathChaos/StompClientLib"

Usage

import StompClientLib

Once imported, you can open a connection to your WebSocket server.

var socketClient = StompClientLib()
let url = NSURL(string: "your-socket-url-is-here")!
socketClient.openSocketWithURLRequest(request: NSURLRequest(url: url as URL) , delegate: self)

After you are connected, there are some delegate methods that you need to implement.

StompClientLibDelegate

stompClientDidConnect

func stompClientDidConnect(client: StompClientLib!) {
print("Socket is connected")
// Stomp subscribe will be here!
socketClient.subscribe(destination: topic)
// Note : topic needs to be a String object
}

stompClientDidDisconnect

func stompClientDidDisconnect(client: StompClientLib!) {
print("Socket is Disconnected")
}

didReceiveMessageWithJSONBody ( Message Received via STOMP )

Your json message will be converted to JSON Body as AnyObject and you will receive your message in this function

func stompClient(client: StompClientLib!, didReceiveMessageWithJSONBody jsonBody: AnyObject?, akaStringBody stringBody: String?, withHeader header: [String : String]?, withDestination destination: String) {
print("Destination : \(destination)")
print("JSON Body : \(String(describing: jsonBody))")
print("String Body : \(stringBody ?? "nil")")
}

didReceiveMessageWithJSONBody ( Message Received via STOMP as String )

Your json message will be converted to JSON Body as AnyObject and you will receive your message in this function

func stompClientJSONBody(client: StompClientLib!, didReceiveMessageWithJSONBody jsonBody: String?, withHeader header: [String : String]?, withDestination destination: String) {
  print("DESTINATION : \(destination)")
  print("String JSON BODY : \(String(describing: jsonBody))")
}

serverDidSendReceipt

If you will use STOMP for in-app purchase, you might need to use this function to get receipt

func serverDidSendReceipt(client: StompClientLib!, withReceiptId receiptId: String) {
  print("Receipt : \(receiptId)")
}

serverDidSendError

Your error message will be received in this function

func serverDidSendError(client: StompClientLib!, withErrorMessage description: String, detailedErrorMessage message: String?) {
  print("Error Send : \(String(describing: message))")
}

serverDidSendPing

If you need to control your server's ping, here is your part

func serverDidSendPing() {
  print("Server ping")
}

How to subscribe and unsubscribe

There are functions for subscribing and unsubscribing. Note : You should handle your subscribe and unsubscribe methods ! Suggestion : Subscribe to your topic in "stompClientDidConnect" function and unsubcribe to your topic in stompClientWillDisconnect method.

socketClient.subscribe(destination: topic)
// Note : topic needs to be a String object

Unsubscribe

socketClient.unsubscribe(destination: topic)

Important : You have to send your destination for both subscribe or unsubscribe!

Unsubsribe with header

let destination = "/topic/your_topic"
let ack = destination
let id = destination
let header = ["destination": destination, "ack": ack, "id": id]

// subscribe
socketClient?.subscribeWithHeader(destination: destination, withHeader: header)

// unsubscribe
socketClient?.unsubscribe(destination: subsId)

Auto Reconnect with a given time

You can use this feature if you need to auto reconnect with a specific time or it will just try to reconnect every second.

// Reconnect after 4 sec
socketClient.reconnect(request: NSURLRequest(url: url as URL) , delegate: self as StompClientLibDelegate, time: 4.0)

Auto Disconnect with a given time

// Auto Disconnect after 3 sec
socketClient.autoDisconnect(time: 3)

Login Passcode Implementation

This is just an example. You need to convert to your implementation. #42

let connectFrame = "CONNECT\n login:admin\n passcode:password\n\n\n\0"
socket.write(string: connectFrame)

Future Enhancements

~~Complete a working Example~~
~~Add Carthage installation option~~
~~Add Swift Package Manager installation option~~
~~XCode 9 compatibility~~
~~Swift 4 compatibility and tests~~
Apple's New Socket for iOS 13 Implementation from stratch

WrathChaos/StompClientLib

WrathChaos

Reviews

Repository Details

StompClientLib

Introduction

Supported Stomp Versions

Example

Requirements

Installation

Cocoapods

Carthage

Usage

StompClientLibDelegate

stompClientDidConnect

stompClientDidDisconnect

didReceiveMessageWithJSONBody ( Message Received via STOMP )

didReceiveMessageWithJSONBody ( Message Received via STOMP as String )

serverDidSendReceipt

serverDidSendError

serverDidSendPing

How to subscribe and unsubscribe

Subscribe

Unsubscribe

Unsubsribe with header

Auto Reconnect with a given time

Auto Disconnect with a given time

Login Passcode Implementation

Future Enhancements

Changelog

1.3.8 (2020-03-08)

1.3.7 (2019-08-26)

1.3.6 (2019-08-06)

1.3.5 (2019-07-25)

1.3.4 (2019-07-19)

1.3.3 (2019-07-18)

1.3.2 (2019-07-10)

1.3.1 (2019-06-14)

1.3.0 (2019-04-30)

1.2.7 (2018-10-23)

1.2.6 (2018-10-23)

1.2.5 (2018-10-22)

1.2.4 (2018-10-17)

1.2.3 (2018-10-17)

1.2.2 (2017-11-03)

1.2.1 (2017-10-31)

1.2.0 (2017-10-29)

1.1.7 (2017-10-02)

1.1.6 (2017-08-08)

0.1.5 (2017-07-10)

0.1.4 (2017-07-10)

0.1.3 (2017-07-10)

0.1.2 (2017-07-08)

0.1.1 (2017-07-08)

0.1.0 (2017-07-08)

Author

License

More Repositories