se

Documentation

Index

• type Session
  • func NewSession(conn bi.Conn, protocol bi.Protocol, timeout time.Duration) *Session
  • func (sess *Session) GetConsumer() *pr.Consumer
  • func (sess *Session) GetLogged() bool
  • func (sess *Session) GetSessionImpl() *bi.SessionImpl
  • func (sess *Session) SetConsumer(consumer *pr.Consumer)
  • func (sess *Session) SetLogged(logged bool)
  • func (sess *Session) Subscribe(topicID string, executeFunc func(sess sp.Session, topicID string) error) error
  • func (sess *Session) Unsubscribe(topicID string, executeFunc func(sess sp.Session, topicID string))
  • func (sess *Session) UnsubscribeAll(executeFunc func(sess sp.Session, topicID string))

Types

type Session

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

Session Session

func NewSession

func NewSession(conn bi.Conn, protocol bi.Protocol, timeout time.Duration) *Session

NewSession NewSession

func (*Session) GetConsumer

func (sess *Session) GetConsumer() *pr.Consumer

GetConsumer GetConsumer

func (*Session) GetLogged

func (sess *Session) GetLogged() bool

GetLogged GetLogged

func (*Session) GetSessionImpl

func (sess *Session) GetSessionImpl() *bi.SessionImpl

GetSessionImpl GetSessionImpl

func (*Session) SetConsumer

func (sess *Session) SetConsumer(consumer *pr.Consumer)

SetConsumer SetConsumer

func (*Session) SetLogged

func (sess *Session) SetLogged(logged bool)

SetLogged SetLogged

func (*Session) Subscribe

func (sess *Session) Subscribe(topicID string, executeFunc func(sess sp.Session, topicID string) error) error

Subscribe Subscribe

func (*Session) Unsubscribe

func (sess *Session) Unsubscribe(topicID string, executeFunc func(sess sp.Session, topicID string))

Unsubscribe Unsubscribe

func (*Session) UnsubscribeAll

func (sess *Session) UnsubscribeAll(executeFunc func(sess sp.Session, topicID string))

UnsubscribeAll UnsubscribeAll