A Go Client for the Eclipse Vert.x TCP EventBus Bridge
This project is a client API for interacting with
Eclipse Vert.x applications from Go applications using the
TCP EventBus bridge from Vert.x.
Usage
You will need the following import
:
import (
// ...
"github.com/jponge/vertx-go-tcp-eventbus-bridge/eventbus"
// ...
)
and go get github.com/jponge/vertx-go-tcp-eventbus-bridge/eventbus
The eventbus
package essentially provides 2 types:
eventbus.EventBus
that encapsulates the TCP bridge protocol, and
eventbus.Dispatcher
that helps receiving messages from the event bus, and dispatch them to
Go channels.
Here is an (incomplete) snippet showing the usage of these 2 types:
// Get an event bus connection
eventBus, err := eventbus.NewEventBus("localhost:7000")
if err != nil {
log.Fatal("Connection to the Vert.x bridge failed: ", err)
}
// Get a dispatcher for incoming messages
dispatcher := eventbus.NewDispatcher(eventBus)
dispatcher.Start()
// Get a queue of length 8 for the messages on 'sample.clock.ticks'
ticks, id, err := dispatcher.Register("sample.clock.ticks", 8)
if err != nil {
log.Fatal("Registration on sample.clock.ticks failed: ", err)
}
log.Println("sample.clock.ticks channel registered with ID=", id)
// Print all ticks from a goroutine
go func() {
for {
<-ticks
log.Println("[tick]")
}
}()
// Post messages to 'sample.echo', and expect replies on 'sample.echo.reply'
go func() {
for {
<-time.After(time.Second * 3)
eventBus.SendWithReplyAddress("sample.echo", "sample.echo.reply", nil, map[string]string{
"source": "Go Client",
"what": "A tick!",
})
}
}()
// Get replies on 'sample.echo.reply'
go func() {
for reply := range(echoReply) {
log.Println("Echo, got back: ", reply)
}
}()
Documentation
You should read the API documentation to understand all operations, and especially the concurrency
assumptions and requirements:
https://godoc.org/github.com/jponge/vertx-go-tcp-eventbus-bridge/eventbus
A sample Vert.x / Java application is given in vertx-sample-app/.
It can be used to run against the sample Go client from
sample-vertx-go-client/.
Finally, the integration tests in eventbus/integration-test/ can be
run using go test
in that folder, and the Vert.x / Java application above needs to be running.
License
Copyright 2016 Julien Ponge
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.