Documentation
¶
Index ¶
- Variables
- func NewQueueServerHandle(o QueueServer) dcerpc.ServerHandle
- func QueueServerHandle(ctx context.Context, o QueueServer, opNum int, r ndr.Reader) (dcerpc.Operation, error)
- func RegisterQueueServer(conn dcerpc.Conn, o QueueServer, opts ...dcerpc.Option)
- type CloseRequest
- type CloseResponse
- type EnableNotificationRequest
- type EnableNotificationResponse
- type GetAccessRequest
- type GetAccessResponse
- type GetHandleRequest
- type GetHandleResponse
- type GetIsOpenRequest
- type GetIsOpenResponse
- type GetQueueInfoRequest
- type GetQueueInfoResponse
- type GetShareModeRequest
- type GetShareModeResponse
- type PeekCurrentRequest
- type PeekCurrentResponse
- type PeekNextRequest
- type PeekNextResponse
- type PeekRequest
- type PeekResponse
- type QueueClient
- type QueueServer
- type ReceiveCurrentRequest
- type ReceiveCurrentResponse
- type ReceiveRequest
- type ReceiveResponse
- type ResetRequest
- type ResetResponse
- type UnimplementedQueueServer
- func (UnimplementedQueueServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)
- func (UnimplementedQueueServer) EnableNotification(context.Context, *EnableNotificationRequest) (*EnableNotificationResponse, error)
- func (UnimplementedQueueServer) GetAccess(context.Context, *GetAccessRequest) (*GetAccessResponse, error)
- func (UnimplementedQueueServer) GetHandle(context.Context, *GetHandleRequest) (*GetHandleResponse, error)
- func (UnimplementedQueueServer) GetIsOpen(context.Context, *GetIsOpenRequest) (*GetIsOpenResponse, error)
- func (UnimplementedQueueServer) GetQueueInfo(context.Context, *GetQueueInfoRequest) (*GetQueueInfoResponse, error)
- func (UnimplementedQueueServer) GetShareMode(context.Context, *GetShareModeRequest) (*GetShareModeResponse, error)
- func (UnimplementedQueueServer) Peek(context.Context, *PeekRequest) (*PeekResponse, error)
- func (UnimplementedQueueServer) PeekCurrent(context.Context, *PeekCurrentRequest) (*PeekCurrentResponse, error)
- func (UnimplementedQueueServer) PeekNext(context.Context, *PeekNextRequest) (*PeekNextResponse, error)
- func (UnimplementedQueueServer) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
- func (UnimplementedQueueServer) ReceiveCurrent(context.Context, *ReceiveCurrentRequest) (*ReceiveCurrentResponse, error)
- func (UnimplementedQueueServer) Reset(context.Context, *ResetRequest) (*ResetResponse, error)
Constants ¶
This section is empty.
Variables ¶
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} )
var (
// import guard
GoPackage = "dcom/mqac"
)
Functions ¶
func NewQueueServerHandle ¶
func NewQueueServerHandle(o QueueServer) dcerpc.ServerHandle
func QueueServerHandle ¶
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 (*CloseRequest) UnmarshalNDR ¶
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 (*CloseResponse) UnmarshalNDR ¶
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 (*EnableNotificationRequest) UnmarshalNDR ¶
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 (*EnableNotificationResponse) UnmarshalNDR ¶
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 (*GetAccessRequest) UnmarshalNDR ¶
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 (*GetAccessResponse) UnmarshalNDR ¶
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 (*GetHandleRequest) UnmarshalNDR ¶
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 (*GetHandleResponse) UnmarshalNDR ¶
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 (*GetIsOpenRequest) UnmarshalNDR ¶
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 (*GetIsOpenResponse) UnmarshalNDR ¶
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 (*GetQueueInfoRequest) UnmarshalNDR ¶
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 (*GetQueueInfoResponse) UnmarshalNDR ¶
type GetShareModeRequest ¶
GetShareModeRequest structure represents the ShareMode operation request
func (*GetShareModeRequest) MarshalNDR ¶
func (*GetShareModeRequest) UnmarshalNDR ¶
type GetShareModeResponse ¶
type GetShareModeResponse struct {
That *dcom.ORPCThat `idl:"name:That" json:"that"`
// 2.2.2.2) enumeration values.
ShareMode int32 `idl:"name:plShareMode" json:"share_mode"`
Return int32 `idl:"name:Return" json:"return"`
}
GetShareModeResponse structure represents the ShareMode operation response
func (*GetShareModeResponse) MarshalNDR ¶
func (*GetShareModeResponse) UnmarshalNDR ¶
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 (*PeekCurrentRequest) UnmarshalNDR ¶
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 (*PeekCurrentResponse) UnmarshalNDR ¶
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 (*PeekNextRequest) UnmarshalNDR ¶
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 (*PeekNextResponse) UnmarshalNDR ¶
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 (*PeekRequest) UnmarshalNDR ¶
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 (*PeekResponse) UnmarshalNDR ¶
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 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 ¶
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 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 (*ReceiveCurrentRequest) UnmarshalNDR ¶
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 (*ReceiveCurrentResponse) UnmarshalNDR ¶
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 (*ReceiveRequest) UnmarshalNDR ¶
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 (*ReceiveResponse) UnmarshalNDR ¶
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 (*ResetRequest) UnmarshalNDR ¶
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 (*ResetResponse) UnmarshalNDR ¶
type UnimplementedQueueServer ¶
type UnimplementedQueueServer struct {
idispatch.UnimplementedDispatchServer
}
Unimplemented IMSMQQueue
func (UnimplementedQueueServer) Close ¶
func (UnimplementedQueueServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)
func (UnimplementedQueueServer) EnableNotification ¶
func (UnimplementedQueueServer) EnableNotification(context.Context, *EnableNotificationRequest) (*EnableNotificationResponse, error)
func (UnimplementedQueueServer) GetAccess ¶
func (UnimplementedQueueServer) GetAccess(context.Context, *GetAccessRequest) (*GetAccessResponse, error)
func (UnimplementedQueueServer) GetHandle ¶
func (UnimplementedQueueServer) GetHandle(context.Context, *GetHandleRequest) (*GetHandleResponse, error)
func (UnimplementedQueueServer) GetIsOpen ¶
func (UnimplementedQueueServer) GetIsOpen(context.Context, *GetIsOpenRequest) (*GetIsOpenResponse, error)
func (UnimplementedQueueServer) GetQueueInfo ¶
func (UnimplementedQueueServer) GetQueueInfo(context.Context, *GetQueueInfoRequest) (*GetQueueInfoResponse, error)
func (UnimplementedQueueServer) GetShareMode ¶
func (UnimplementedQueueServer) GetShareMode(context.Context, *GetShareModeRequest) (*GetShareModeResponse, error)
func (UnimplementedQueueServer) Peek ¶
func (UnimplementedQueueServer) Peek(context.Context, *PeekRequest) (*PeekResponse, error)
func (UnimplementedQueueServer) PeekCurrent ¶
func (UnimplementedQueueServer) PeekCurrent(context.Context, *PeekCurrentRequest) (*PeekCurrentResponse, error)
func (UnimplementedQueueServer) PeekNext ¶
func (UnimplementedQueueServer) PeekNext(context.Context, *PeekNextRequest) (*PeekNextResponse, error)
func (UnimplementedQueueServer) Receive ¶
func (UnimplementedQueueServer) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
func (UnimplementedQueueServer) ReceiveCurrent ¶
func (UnimplementedQueueServer) ReceiveCurrent(context.Context, *ReceiveCurrentRequest) (*ReceiveCurrentResponse, error)
func (UnimplementedQueueServer) Reset ¶
func (UnimplementedQueueServer) Reset(context.Context, *ResetRequest) (*ResetResponse, error)