BackendImplementor returns the queue backend service implementor.

IdempotentImplementor returns the idempotent service implementor.

Implementor returns the queue service implementor.

RegisterBackendImplementor registers the queue backend service implementor.

RegisterIdempotentImplementor registers the idempotent service implementor.

RegisterImplementor registers the queue service implementor.

StreamServerInterceptor returns a new streaming server interceptor for message queue service.

UnaryServerInterceptor returns a new unary server interceptor for message queue service.

Backend interface.

Consumer handler interface.

Idempotent interface.

Message interface.

MessageOperation interface.

MessageWrapper interface.

ProcessStatus type.