Publishing Messages
Individually Publishing
Messages can be sent individually to the Sybline Cluster.
Full Code Example:
passwordManager := handler.NewUnsecurePasswordManager()
passwordManager.SetPassword("sybline", "sybline")
client, err := handler.NewBasicSyblineClient([]string{"localhost:2221", "localhost:2222", "localhost:2223"}, passwordManager, handler.Config{
TimeoutSec: 5,
TimeoutAttempts: 3,
})
if err != nil {
log.Fatal("error cannot connect:", err)
}
ctx := context.Background()
// this is the critical step that includes your headers
if err := client.Login(ctx, "sybline"); err != nil {
log.Fatal("error login:", err)
}
amount := uint32(10)
queueName := "randomOne"
if err := client.CreateQueue(ctx, "random", queueName, amount); err != nil {
log.Fatal("error queue:", err)
}
if err := client.SubmitMessage(ctx, "random", []byte("data")); err != nil {
fmt.Println("error submit:", err, i)
}
Batch Publishing
Messages can also be sent in batches, must more efficient than send messages one at a time. The benefits are
- It reduces the number of logs that have to be stored
- Entries can be inserted as one block as if it was a single message
- Allows you to mix routes into a single batch e.g. you can send two different routes in the same batch process
Full Code example:
passwordManager := handler.NewUnsecurePasswordManager()
passwordManager.SetPassword("sybline", "sybline")
client, err := handler.NewBasicSyblineClient([]string{"localhost:2221", "localhost:2222", "localhost:2223"}, passwordManager, handler.Config{
TimeoutSec: 5,
TimeoutAttempts: 3,
})
if err != nil {
log.Fatal("error cannot connect:", err)
}
ctx := context.Background()
// this is the critical step that includes your headers
if err := client.Login(ctx, "sybline"); err != nil {
log.Fatal("error login:", err)
}
amount := uint32(10)
queueName := "randomOne"
route := "random"
if err := client.CreateQueue(ctx, route, queueName, amount); err != nil {
log.Fatal("error queue:", err)
}
messages := []handler.Message{
{
Rk: route,
Data: []byte("data0"),
},
{
Rk: route,
Data: []byte("data1"),
},
{
Rk: route,
Data: []byte("data2"),
},
{
Rk: route,
Data: []byte("data3"),
},
}
if err := client.SubmitBatchMessage(ctx, messages); err != nil {
fmt.Println("error submit:", err)
}