imsmqqueue

package
v1.2.16 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 22, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// IMSMQQueue interface identifier d7d6e076-dccd-11d0-aa4b-0060970debae
	QueueIID = &dcom.IID{Data1: 0xd7d6e076, Data2: 0xdccd, Data3: 0x11d0, Data4: []byte{0xaa, 0x4b, 0x00, 0x60, 0x97, 0x0d, 0xeb, 0xae}}
	// Syntax UUID
	QueueSyntaxUUID = &uuid.UUID{TimeLow: 0xd7d6e076, TimeMid: 0xdccd, TimeHiAndVersion: 0x11d0, ClockSeqHiAndReserved: 0xaa, ClockSeqLow: 0x4b, Node: [6]uint8{0x0, 0x60, 0x97, 0xd, 0xeb, 0xae}}
	// Syntax ID
	QueueSyntaxV0_0 = &dcerpc.SyntaxID{IfUUID: QueueSyntaxUUID, IfVersionMajor: 0, IfVersionMinor: 0}
)
View Source
var (
	// import guard
	GoPackage = "dcom/mqac"
)

Functions

func NewQueueServerHandle

func NewQueueServerHandle(o QueueServer) dcerpc.ServerHandle

func QueueServerHandle

func QueueServerHandle(ctx context.Context, o QueueServer, opNum int, r ndr.Reader) (dcerpc.Operation, error)

func RegisterQueueServer

func RegisterQueueServer(conn dcerpc.Conn, o QueueServer, opts ...dcerpc.Option)

Types

type CloseRequest

type CloseRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

CloseRequest structure represents the Close operation request

func (*CloseRequest) MarshalNDR

func (o *CloseRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*CloseRequest) UnmarshalNDR

func (o *CloseRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type CloseResponse

type CloseResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// Return: The Close return value.
	Return int32 `idl:"name:Return" json:"return"`
}

CloseResponse structure represents the Close operation response

func (*CloseResponse) MarshalNDR

func (o *CloseResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*CloseResponse) UnmarshalNDR

func (o *CloseResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type EnableNotificationRequest

type EnableNotificationRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// Event: A pointer to an IMSMQEvent3 interface. If Event is NULL, the server MUST return
	// an error E_INVALIDARG (0x80070057).
	Event *mqac.Event `idl:"name:Event" json:"event"`
	// Cursor: A VARIANT pointer to a signed integer that corresponds to one of the MQMSGCURSOR
	// ( section 2.2.2.8) enumeration values.
	Cursor *oaut.Variant `idl:"name:Cursor" json:"cursor"`
	// ReceiveTimeout: A pointer to a VARIANT that contains a long value (VT_I4) that specifies
	// the time, in milliseconds, that the server MUST NOT exceed while waiting for a new
	// message to arrive.
	ReceiveTimeout *oaut.Variant `idl:"name:ReceiveTimeout" json:"receive_timeout"`
}

EnableNotificationRequest structure represents the EnableNotification operation request

func (*EnableNotificationRequest) MarshalNDR

func (o *EnableNotificationRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*EnableNotificationRequest) UnmarshalNDR

func (o *EnableNotificationRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type EnableNotificationResponse

type EnableNotificationResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// Return: The EnableNotification return value.
	Return int32 `idl:"name:Return" json:"return"`
}

EnableNotificationResponse structure represents the EnableNotification operation response

func (*EnableNotificationResponse) MarshalNDR

func (o *EnableNotificationResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*EnableNotificationResponse) UnmarshalNDR

func (o *EnableNotificationResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetAccessRequest

type GetAccessRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

GetAccessRequest structure represents the Access operation request

func (*GetAccessRequest) MarshalNDR

func (o *GetAccessRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetAccessRequest) UnmarshalNDR

func (o *GetAccessRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetAccessResponse

type GetAccessResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// plAccess: A pointer to a long that corresponds to one of the MQACCESS (section 2.2.2.3)
	// enumeration values.
	Access int32 `idl:"name:plAccess" json:"access"`
	// Return: The Access return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetAccessResponse structure represents the Access operation response

func (*GetAccessResponse) MarshalNDR

func (o *GetAccessResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetAccessResponse) UnmarshalNDR

func (o *GetAccessResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetHandleRequest

type GetHandleRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

GetHandleRequest structure represents the Handle operation request

func (*GetHandleRequest) MarshalNDR

func (o *GetHandleRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetHandleRequest) UnmarshalNDR

func (o *GetHandleRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetHandleResponse

type GetHandleResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That   *dcom.ORPCThat `idl:"name:That" json:"that"`
	Handle int32          `idl:"name:plHandle" json:"handle"`
	// Return: The Handle return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetHandleResponse structure represents the Handle operation response

func (*GetHandleResponse) MarshalNDR

func (o *GetHandleResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetHandleResponse) UnmarshalNDR

func (o *GetHandleResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetIsOpenRequest

type GetIsOpenRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

GetIsOpenRequest structure represents the IsOpen operation request

func (*GetIsOpenRequest) MarshalNDR

func (o *GetIsOpenRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetIsOpenRequest) UnmarshalNDR

func (o *GetIsOpenRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetIsOpenResponse

type GetIsOpenResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That   *dcom.ORPCThat `idl:"name:That" json:"that"`
	IsOpen int16          `idl:"name:pisOpen" json:"is_open"`
	// Return: The IsOpen return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetIsOpenResponse structure represents the IsOpen operation response

func (*GetIsOpenResponse) MarshalNDR

func (o *GetIsOpenResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetIsOpenResponse) UnmarshalNDR

func (o *GetIsOpenResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetQueueInfoRequest

type GetQueueInfoRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

GetQueueInfoRequest structure represents the QueueInfo operation request

func (*GetQueueInfoRequest) MarshalNDR

func (o *GetQueueInfoRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetQueueInfoRequest) UnmarshalNDR

func (o *GetQueueInfoRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetQueueInfoResponse

type GetQueueInfoResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// ppqinfo: A pointer to an IMSMQQueueInfo4 interface pointer that contains the MSMQQueueInfo
	// object that represents the referenced queue.
	QueueInfo *mqac.QueueInfo `idl:"name:ppqinfo" json:"queue_info"`
	// Return: The QueueInfo return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetQueueInfoResponse structure represents the QueueInfo operation response

func (*GetQueueInfoResponse) MarshalNDR

func (o *GetQueueInfoResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetQueueInfoResponse) UnmarshalNDR

func (o *GetQueueInfoResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetShareModeRequest

type GetShareModeRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

GetShareModeRequest structure represents the ShareMode operation request

func (*GetShareModeRequest) MarshalNDR

func (o *GetShareModeRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetShareModeRequest) UnmarshalNDR

func (o *GetShareModeRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetShareModeResponse

type GetShareModeResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// plShareMode: A pointer to a long that corresponds to one of the MQSHARE (section
	// 2.2.2.2) enumeration values.
	ShareMode int32 `idl:"name:plShareMode" json:"share_mode"`
	// Return: The ShareMode return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetShareModeResponse structure represents the ShareMode operation response

func (*GetShareModeResponse) MarshalNDR

func (o *GetShareModeResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetShareModeResponse) UnmarshalNDR

func (o *GetShareModeResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type PeekCurrentRequest

type PeekCurrentRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// WantDestinationQueue: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_FALSE (0x0000) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | The server MUST return an MSMQMessage object that has the DestinationQueueInfo   |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the     |
	//	|                      | DestinationQueueInfo property set.                                               |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantDestinationQueue *oaut.Variant `idl:"name:WantDestinationQueue" json:"want_destination_queue"`
	// WantBody: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_TRUE (0xFFFF) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | Default. The server MUST return an MSMQMessage object that has the Body property |
	//	|                      | set.                                                                             |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | The server MUST return an MSMQMessage object that does not have the Body         |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantBody *oaut.Variant `idl:"name:WantBody" json:"want_body"`
	// ReceiveTimeout: A pointer to a VARIANT that contains a long value (VT_I4) that specifies
	// the time, in milliseconds, that the server MUST NOT exceed while waiting for a new
	// message to arrive.
	ReceiveTimeout *oaut.Variant `idl:"name:ReceiveTimeout" json:"receive_timeout"`
}

PeekCurrentRequest structure represents the PeekCurrent operation request

func (*PeekCurrentRequest) MarshalNDR

func (o *PeekCurrentRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*PeekCurrentRequest) UnmarshalNDR

func (o *PeekCurrentRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type PeekCurrentResponse

type PeekCurrentResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// ppmsg: A pointer to a pointer to an IMSMQMessage4 interface that MUST be set by the
	// server with the received message.
	Message *mqac.Message `idl:"name:ppmsg" json:"message"`
	// Return: The PeekCurrent return value.
	Return int32 `idl:"name:Return" json:"return"`
}

PeekCurrentResponse structure represents the PeekCurrent operation response

func (*PeekCurrentResponse) MarshalNDR

func (o *PeekCurrentResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*PeekCurrentResponse) UnmarshalNDR

func (o *PeekCurrentResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type PeekNextRequest

type PeekNextRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// WantDestinationQueue: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_FALSE (0x0000) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | The server MUST return an MSMQMessage object that has the DestinationQueueInfo   |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the     |
	//	|                      | DestinationQueueInfo property set.                                               |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantDestinationQueue *oaut.Variant `idl:"name:WantDestinationQueue" json:"want_destination_queue"`
	// WantBody: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_TRUE (0xFFFF) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | Default. The server MUST return an MSMQMessage object that has the Body property |
	//	|                      | set.                                                                             |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | The server MUST return an MSMQMessage object that does not have the Body         |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantBody *oaut.Variant `idl:"name:WantBody" json:"want_body"`
	// ReceiveTimeout: A pointer to a VARIANT that contains a long value (VT_I4) that specifies
	// the time, in milliseconds, that the server MUST NOT exceed while waiting for a new
	// message to arrive.
	ReceiveTimeout *oaut.Variant `idl:"name:ReceiveTimeout" json:"receive_timeout"`
}

PeekNextRequest structure represents the PeekNext operation request

func (*PeekNextRequest) MarshalNDR

func (o *PeekNextRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*PeekNextRequest) UnmarshalNDR

func (o *PeekNextRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type PeekNextResponse

type PeekNextResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// ppmsg: A pointer to a pointer to an IMSMQMessage4 interface that MUST be set by the
	// server with the received message.
	Message *mqac.Message `idl:"name:ppmsg" json:"message"`
	// Return: The PeekNext return value.
	Return int32 `idl:"name:Return" json:"return"`
}

PeekNextResponse structure represents the PeekNext operation response

func (*PeekNextResponse) MarshalNDR

func (o *PeekNextResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*PeekNextResponse) UnmarshalNDR

func (o *PeekNextResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type PeekRequest

type PeekRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// WantDestinationQueue: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_FALSE (0x0000) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | The server MUST return an MSMQMessage object that has the DestinationQueueInfo   |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the     |
	//	|                      | DestinationQueueInfo property set.                                               |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantDestinationQueue *oaut.Variant `idl:"name:WantDestinationQueue" json:"want_destination_queue"`
	// WantBody: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_TRUE (0xFFFF) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | Default. The server MUST return an MSMQMessage object that has the Body property |
	//	|                      | set.                                                                             |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | The server MUST return an MSMQMessage object that does not have the Body         |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantBody *oaut.Variant `idl:"name:WantBody" json:"want_body"`
	// ReceiveTimeout: A pointer to a VARIANT that contains a long value (VT_I4) that specifies
	// the time, in milliseconds, that the server MUST NOT exceed while waiting for a new
	// message to arrive.
	ReceiveTimeout *oaut.Variant `idl:"name:ReceiveTimeout" json:"receive_timeout"`
}

PeekRequest structure represents the Peek operation request

func (*PeekRequest) MarshalNDR

func (o *PeekRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*PeekRequest) UnmarshalNDR

func (o *PeekRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type PeekResponse

type PeekResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// ppmsg: A pointer to a pointer to an IMSMQMessage4 interface that MUST be set by the
	// server with the received message.
	Message *mqac.Message `idl:"name:ppmsg" json:"message"`
	// Return: The Peek return value.
	Return int32 `idl:"name:Return" json:"return"`
}

PeekResponse structure represents the Peek operation response

func (*PeekResponse) MarshalNDR

func (o *PeekResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*PeekResponse) UnmarshalNDR

func (o *PeekResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type QueueClient

type QueueClient interface {

	// IDispatch retrieval method.
	Dispatch() idispatch.DispatchClient

	// The Access method is received by the server in an RPC_REQUEST packet. In response,
	// the server returns a flag that indicates the access mode in which the queue was opened.
	// The access mode specifies whether peek, receive, send, and/or administration operations
	// can be performed.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	GetAccess(context.Context, *GetAccessRequest, ...dcerpc.CallOption) (*GetAccessResponse, error)

	// The ShareMode method is received by the server in an RPC_REQUEST packet. In response,
	// the server returns a flag that indicates the share mode in which the queue was opened.
	// The share mode specifies whether this instance of the open queue has exclusive access
	// to the queue.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	GetShareMode(context.Context, *GetShareModeRequest, ...dcerpc.CallOption) (*GetShareModeResponse, error)

	// The QueueInfo method is received by the server in an RPC_REQUEST packet. In response,
	// the server returns an MSMQQueueInfo object that represents the referenced queue.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	GetQueueInfo(context.Context, *GetQueueInfoRequest, ...dcerpc.CallOption) (*GetQueueInfoResponse, error)

	// Handle operation.
	GetHandle(context.Context, *GetHandleRequest, ...dcerpc.CallOption) (*GetHandleResponse, error)

	// IsOpen operation.
	GetIsOpen(context.Context, *GetIsOpenRequest, ...dcerpc.CallOption) (*GetIsOpenResponse, error)

	// Close operation.
	Close(context.Context, *CloseRequest, ...dcerpc.CallOption) (*CloseResponse, error)

	// The Receive method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message at the head of the referenced queue's MessagePositionList
	// and removes it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	Receive(context.Context, *ReceiveRequest, ...dcerpc.CallOption) (*ReceiveResponse, error)

	// The Peek method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message at the head of the referenced queue's MessagePositionList
	// without removing it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	Peek(context.Context, *PeekRequest, ...dcerpc.CallOption) (*PeekResponse, error)

	// The EnableNotification method is received by the server in an RPC_REQUEST packet.
	// In response, the server starts event notification for asynchronously receiving or
	// peeking messages.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	EnableNotification(context.Context, *EnableNotificationRequest, ...dcerpc.CallOption) (*EnableNotificationResponse, error)

	// Reset operation.
	Reset(context.Context, *ResetRequest, ...dcerpc.CallOption) (*ResetResponse, error)

	// The ReceiveCurrent method is received by the server in an RPC_REQUEST packet. In
	// response, the server retrieves the Message that is identified by the Cursor instance
	// variable in the referenced queue's MessagePositionList and removes it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	ReceiveCurrent(context.Context, *ReceiveCurrentRequest, ...dcerpc.CallOption) (*ReceiveCurrentResponse, error)

	// The PeekNext method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message that follows the Message that is identified by the
	// Cursor instance variable in the referenced queue's MessagePositionList without removing
	// it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	PeekNext(context.Context, *PeekNextRequest, ...dcerpc.CallOption) (*PeekNextResponse, error)

	// The PeekCurrent method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message that is identified by the Cursor instance variable
	// in the referenced queue's MessagePositionList, without removing it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	PeekCurrent(context.Context, *PeekCurrentRequest, ...dcerpc.CallOption) (*PeekCurrentResponse, error)

	// AlterContext alters the client context.
	AlterContext(context.Context, ...dcerpc.Option) error

	// Conn returns the client connection (unsafe)
	Conn() dcerpc.Conn

	// IPID sets the object interface identifier.
	IPID(context.Context, *dcom.IPID) QueueClient
}

IMSMQQueue interface.

func NewQueueClient

func NewQueueClient(ctx context.Context, cc dcerpc.Conn, opts ...dcerpc.Option) (QueueClient, error)

type QueueServer

type QueueServer interface {

	// IDispatch base class.
	idispatch.DispatchServer

	// The Access method is received by the server in an RPC_REQUEST packet. In response,
	// the server returns a flag that indicates the access mode in which the queue was opened.
	// The access mode specifies whether peek, receive, send, and/or administration operations
	// can be performed.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	GetAccess(context.Context, *GetAccessRequest) (*GetAccessResponse, error)

	// The ShareMode method is received by the server in an RPC_REQUEST packet. In response,
	// the server returns a flag that indicates the share mode in which the queue was opened.
	// The share mode specifies whether this instance of the open queue has exclusive access
	// to the queue.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	GetShareMode(context.Context, *GetShareModeRequest) (*GetShareModeResponse, error)

	// The QueueInfo method is received by the server in an RPC_REQUEST packet. In response,
	// the server returns an MSMQQueueInfo object that represents the referenced queue.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	GetQueueInfo(context.Context, *GetQueueInfoRequest) (*GetQueueInfoResponse, error)

	// Handle operation.
	GetHandle(context.Context, *GetHandleRequest) (*GetHandleResponse, error)

	// IsOpen operation.
	GetIsOpen(context.Context, *GetIsOpenRequest) (*GetIsOpenResponse, error)

	// Close operation.
	Close(context.Context, *CloseRequest) (*CloseResponse, error)

	// The Receive method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message at the head of the referenced queue's MessagePositionList
	// and removes it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)

	// The Peek method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message at the head of the referenced queue's MessagePositionList
	// without removing it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	Peek(context.Context, *PeekRequest) (*PeekResponse, error)

	// The EnableNotification method is received by the server in an RPC_REQUEST packet.
	// In response, the server starts event notification for asynchronously receiving or
	// peeking messages.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	EnableNotification(context.Context, *EnableNotificationRequest) (*EnableNotificationResponse, error)

	// Reset operation.
	Reset(context.Context, *ResetRequest) (*ResetResponse, error)

	// The ReceiveCurrent method is received by the server in an RPC_REQUEST packet. In
	// response, the server retrieves the Message that is identified by the Cursor instance
	// variable in the referenced queue's MessagePositionList and removes it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	ReceiveCurrent(context.Context, *ReceiveCurrentRequest) (*ReceiveCurrentResponse, error)

	// The PeekNext method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message that follows the Message that is identified by the
	// Cursor instance variable in the referenced queue's MessagePositionList without removing
	// it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	PeekNext(context.Context, *PeekNextRequest) (*PeekNextResponse, error)

	// The PeekCurrent method is received by the server in an RPC_REQUEST packet. In response,
	// the server retrieves the Message that is identified by the Cursor instance variable
	// in the referenced queue's MessagePositionList, without removing it.
	//
	// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
	// error HRESULT on failure.
	PeekCurrent(context.Context, *PeekCurrentRequest) (*PeekCurrentResponse, error)
}

IMSMQQueue server interface.

type ReceiveCurrentRequest

type ReceiveCurrentRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// Transaction: A pointer to a VARIANT that MUST contain either of the following:
	//
	//	A VT_DISPATCH or a VT_DISPATCH | VT_BYREF that points to an MSMQTransaction object.
	//
	// A VT_I4 that corresponds to one of the MQTRANSACTION (section 2.2.2.1) enumeration
	// values.
	Transaction *oaut.Variant `idl:"name:Transaction" json:"transaction"`
	// WantDestinationQueue: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_FALSE (0x0000) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | The server MUST return an MSMQMessage object that has the DestinationQueueInfo   |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the     |
	//	|                      | DestinationQueueInfo property set.                                               |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantDestinationQueue *oaut.Variant `idl:"name:WantDestinationQueue" json:"want_destination_queue"`
	// WantBody: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_TRUE (0xFFFF) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | Default. The server MUST return an MSMQMessage object that has the Body property |
	//	|                      | set.                                                                             |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | The server MUST return an MSMQMessage object that does not have the Body         |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantBody *oaut.Variant `idl:"name:WantBody" json:"want_body"`
	// ReceiveTimeout: A pointer to a VARIANT that contains a long value (VT_I4) that specifies
	// the time, in milliseconds, that the server MUST NOT exceed while waiting for a new
	// message to arrive.
	ReceiveTimeout *oaut.Variant `idl:"name:ReceiveTimeout" json:"receive_timeout"`
}

ReceiveCurrentRequest structure represents the ReceiveCurrent operation request

func (*ReceiveCurrentRequest) MarshalNDR

func (o *ReceiveCurrentRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*ReceiveCurrentRequest) UnmarshalNDR

func (o *ReceiveCurrentRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type ReceiveCurrentResponse

type ReceiveCurrentResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// ppmsg: A pointer to a pointer to an IMSMQMessage4 interface that MUST be set by the
	// server with the received message.
	Message *mqac.Message `idl:"name:ppmsg" json:"message"`
	// Return: The ReceiveCurrent return value.
	Return int32 `idl:"name:Return" json:"return"`
}

ReceiveCurrentResponse structure represents the ReceiveCurrent operation response

func (*ReceiveCurrentResponse) MarshalNDR

func (o *ReceiveCurrentResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*ReceiveCurrentResponse) UnmarshalNDR

func (o *ReceiveCurrentResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type ReceiveRequest

type ReceiveRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// Transaction: A pointer to a VARIANT that MUST contain either of the following:
	//
	//	A VT_DISPATCH or a VT_DISPATCH | VT_BYREF that points to an MSMQTransaction object.
	//
	// A VT_I4 that corresponds to one of the MQTRANSACTION (section 2.2.2.1) enumeration
	// values.
	Transaction *oaut.Variant `idl:"name:Transaction" json:"transaction"`
	// WantDestinationQueue: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_FALSE (0x0000) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | The server MUST return an MSMQMessage object that has the DestinationQueueInfo   |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the     |
	//	|                      | DestinationQueueInfo property set.                                               |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantDestinationQueue *oaut.Variant `idl:"name:WantDestinationQueue" json:"want_destination_queue"`
	// WantBody: A pointer to a VARIANT (VT_BOOL).
	//
	// If this parameter is not specified by the client, the server MUST use the default
	// value VARIANT_TRUE (0xFFFF) in place of the unspecified value.
	//
	//	+----------------------+----------------------------------------------------------------------------------+
	//	|                      |                                                                                  |
	//	|        VALUE         |                                     MEANING                                      |
	//	|                      |                                                                                  |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_TRUE 0xFFFF  | Default. The server MUST return an MSMQMessage object that has the Body property |
	//	|                      | set.                                                                             |
	//	+----------------------+----------------------------------------------------------------------------------+
	//	| VARIANT_FALSE 0x0000 | The server MUST return an MSMQMessage object that does not have the Body         |
	//	|                      | property set.                                                                    |
	//	+----------------------+----------------------------------------------------------------------------------+
	WantBody *oaut.Variant `idl:"name:WantBody" json:"want_body"`
	// ReceiveTimeout: A pointer to a VARIANT that contains a long value (VT_I4) that specifies
	// the time, in milliseconds, that the server MUST NOT exceed while waiting for a new
	// message to arrive.
	ReceiveTimeout *oaut.Variant `idl:"name:ReceiveTimeout" json:"receive_timeout"`
}

ReceiveRequest structure represents the Receive operation request

func (*ReceiveRequest) MarshalNDR

func (o *ReceiveRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*ReceiveRequest) UnmarshalNDR

func (o *ReceiveRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type ReceiveResponse

type ReceiveResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// ppmsg: A pointer to a pointer to an IMSMQMessage4 interface that MUST be set by the
	// server with the received message.
	Message *mqac.Message `idl:"name:ppmsg" json:"message"`
	// Return: The Receive return value.
	Return int32 `idl:"name:Return" json:"return"`
}

ReceiveResponse structure represents the Receive operation response

func (*ReceiveResponse) MarshalNDR

func (o *ReceiveResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*ReceiveResponse) UnmarshalNDR

func (o *ReceiveResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type ResetRequest

type ResetRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
}

ResetRequest structure represents the Reset operation request

func (*ResetRequest) MarshalNDR

func (o *ResetRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*ResetRequest) UnmarshalNDR

func (o *ResetRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type ResetResponse

type ResetResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// Return: The Reset return value.
	Return int32 `idl:"name:Return" json:"return"`
}

ResetResponse structure represents the Reset operation response

func (*ResetResponse) MarshalNDR

func (o *ResetResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*ResetResponse) UnmarshalNDR

func (o *ResetResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type UnimplementedQueueServer

type UnimplementedQueueServer struct {
	idispatch.UnimplementedDispatchServer
}

Unimplemented IMSMQQueue

func (UnimplementedQueueServer) Close

func (UnimplementedQueueServer) GetAccess

func (UnimplementedQueueServer) GetHandle

func (UnimplementedQueueServer) GetIsOpen

func (UnimplementedQueueServer) GetQueueInfo

func (UnimplementedQueueServer) GetShareMode

func (UnimplementedQueueServer) Peek

func (UnimplementedQueueServer) PeekCurrent

func (UnimplementedQueueServer) PeekNext

func (UnimplementedQueueServer) Receive

func (UnimplementedQueueServer) ReceiveCurrent

func (UnimplementedQueueServer) Reset

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL