javaclient

Documentation

Index

• Constants
• type ClientBuilder
  • func NewClientBuilder(name string, command JavaClientCmd, ctx framework.ContextData, url string) *ClientBuilder
  • func (s *ClientBuilder) Address(addr string) *ClientBuilder
  • func (s *ClientBuilder) Build() *JavaClient
  • func (s *ClientBuilder) EnableTracing() *ClientBuilder
  • func (s *ClientBuilder) EnvVar(variable, value string) *ClientBuilder
  • func (s *ClientBuilder) ImageCustom(image string) *ClientBuilder
  • func (s *ClientBuilder) Timeout(timeout int) *ClientBuilder
• type JavaClient
  • func (p *JavaClient) Result() amqp.ResultData
• type JavaClientCmd
• type JavaClientResult

Constants

const (
	JavaClientImage   string        = "docker.io/qdrshipshape/examples-java-basic:latest"
	JavaBasicSender   JavaClientCmd = "com.github.rhmessaging.qdrshipshape.examples.basic.client.BasicSender"
	JavaBasicReceiver JavaClientCmd = "com.github.rhmessaging.qdrshipshape.examples.basic.client.BasicReceiver"
)

Types

type ClientBuilder

type ClientBuilder struct {
	// contains filtered or unexported fields
}

func NewClientBuilder

func NewClientBuilder(name string, command JavaClientCmd, ctx framework.ContextData, url string) *ClientBuilder

func (*ClientBuilder) Address

func (s *ClientBuilder) Address(addr string) *ClientBuilder

Address to use

func (*ClientBuilder) Build

func (s *ClientBuilder) Build() *JavaClient

func (*ClientBuilder) EnableTracing

func (s *ClientBuilder) EnableTracing() *ClientBuilder

func (*ClientBuilder) EnvVar

func (s *ClientBuilder) EnvVar(variable, value string) *ClientBuilder

func (*ClientBuilder) ImageCustom

func (s *ClientBuilder) ImageCustom(image string) *ClientBuilder

func (*ClientBuilder) Timeout

func (s *ClientBuilder) Timeout(timeout int) *ClientBuilder

Timeout sets the amount of secs to wait before timing out

type JavaClient

type JavaClient struct {
	amqp.AmqpClientCommon
}

func (*JavaClient) Result

func (p *JavaClient) Result() amqp.ResultData

type JavaClientCmd

type JavaClientCmd string

type JavaClientResult

type JavaClientResult struct {
	Delivered int    `json:"delivered"`
	Released  int    `json:"released"`
	Rejected  int    `json:"rejected"`
	Modified  int    `json:"modified"`
	Accepted  int    `json:"accepted"`
	ErrorMsg  string `json:"errormsg"`
}