Documentation
¶
Index ¶
- Variables
- func NewQueue2ServerHandle(o Queue2Server) dcerpc.ServerHandle
- func Queue2ServerHandle(ctx context.Context, o Queue2Server, opNum int, r ndr.Reader) (dcerpc.Operation, error)
- func RegisterQueue2Server(conn dcerpc.Conn, o Queue2Server, opts ...dcerpc.Option)
- type CloseRequest
- type CloseResponse
- type EnableNotificationRequest
- type EnableNotificationResponse
- type GetAccessRequest
- type GetAccessResponse
- type GetHandleRequest
- type GetHandleResponse
- type GetIsOpenRequest
- type GetIsOpenResponse
- type GetPropertiesRequest
- type GetPropertiesResponse
- type GetQueueInfoRequest
- type GetQueueInfoResponse
- type GetShareModeRequest
- type GetShareModeResponse
- type PeekCurrentRequest
- type PeekCurrentResponse
- type PeekCurrentV1Request
- type PeekCurrentV1Response
- type PeekNextRequest
- type PeekNextResponse
- type PeekNextV1Request
- type PeekNextV1Response
- type PeekRequest
- type PeekResponse
- type PeekV1Request
- type PeekV1Response
- type Queue2Client
- type Queue2Server
- type ReceiveCurrentRequest
- type ReceiveCurrentResponse
- type ReceiveCurrentV1Request
- type ReceiveCurrentV1Response
- type ReceiveRequest
- type ReceiveResponse
- type ReceiveV1Request
- type ReceiveV1Response
- type ResetRequest
- type ResetResponse
- type UnimplementedQueue2Server
- func (UnimplementedQueue2Server) Close(context.Context, *CloseRequest) (*CloseResponse, error)
- func (UnimplementedQueue2Server) EnableNotification(context.Context, *EnableNotificationRequest) (*EnableNotificationResponse, error)
- func (UnimplementedQueue2Server) GetAccess(context.Context, *GetAccessRequest) (*GetAccessResponse, error)
- func (UnimplementedQueue2Server) GetHandle(context.Context, *GetHandleRequest) (*GetHandleResponse, error)
- func (UnimplementedQueue2Server) GetIsOpen(context.Context, *GetIsOpenRequest) (*GetIsOpenResponse, error)
- func (UnimplementedQueue2Server) GetProperties(context.Context, *GetPropertiesRequest) (*GetPropertiesResponse, error)
- func (UnimplementedQueue2Server) GetQueueInfo(context.Context, *GetQueueInfoRequest) (*GetQueueInfoResponse, error)
- func (UnimplementedQueue2Server) GetShareMode(context.Context, *GetShareModeRequest) (*GetShareModeResponse, error)
- func (UnimplementedQueue2Server) Peek(context.Context, *PeekRequest) (*PeekResponse, error)
- func (UnimplementedQueue2Server) PeekCurrent(context.Context, *PeekCurrentRequest) (*PeekCurrentResponse, error)
- func (UnimplementedQueue2Server) PeekCurrentV1(context.Context, *PeekCurrentV1Request) (*PeekCurrentV1Response, error)
- func (UnimplementedQueue2Server) PeekNext(context.Context, *PeekNextRequest) (*PeekNextResponse, error)
- func (UnimplementedQueue2Server) PeekNextV1(context.Context, *PeekNextV1Request) (*PeekNextV1Response, error)
- func (UnimplementedQueue2Server) PeekV1(context.Context, *PeekV1Request) (*PeekV1Response, error)
- func (UnimplementedQueue2Server) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
- func (UnimplementedQueue2Server) ReceiveCurrent(context.Context, *ReceiveCurrentRequest) (*ReceiveCurrentResponse, error)
- func (UnimplementedQueue2Server) ReceiveCurrentV1(context.Context, *ReceiveCurrentV1Request) (*ReceiveCurrentV1Response, error)
- func (UnimplementedQueue2Server) ReceiveV1(context.Context, *ReceiveV1Request) (*ReceiveV1Response, error)
- func (UnimplementedQueue2Server) Reset(context.Context, *ResetRequest) (*ResetResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ( // IMSMQQueue2 interface identifier ef0574e0-06d8-11d3-b100-00e02c074f6b Queue2IID = &dcom.IID{Data1: 0xef0574e0, Data2: 0x06d8, Data3: 0x11d3, Data4: []byte{0xb1, 0x00, 0x00, 0xe0, 0x2c, 0x07, 0x4f, 0x6b}} // Syntax UUID Queue2SyntaxUUID = &uuid.UUID{TimeLow: 0xef0574e0, TimeMid: 0x6d8, TimeHiAndVersion: 0x11d3, ClockSeqHiAndReserved: 0xb1, ClockSeqLow: 0x0, Node: [6]uint8{0x0, 0xe0, 0x2c, 0x7, 0x4f, 0x6b}} // Syntax ID Queue2SyntaxV0_0 = &dcerpc.SyntaxID{IfUUID: Queue2SyntaxUUID, IfVersionMajor: 0, IfVersionMinor: 0} )
var (
// import guard
GoPackage = "dcom/mqac"
)
Functions ¶
func NewQueue2ServerHandle ¶
func NewQueue2ServerHandle(o Queue2Server) dcerpc.ServerHandle
func Queue2ServerHandle ¶
func RegisterQueue2Server ¶
func RegisterQueue2Server(conn dcerpc.Conn, o Queue2Server, 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.Event2 `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 GetPropertiesRequest ¶
type GetPropertiesRequest struct {
// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
This *dcom.ORPCThis `idl:"name:This" json:"this"`
}
GetPropertiesRequest structure represents the Properties operation request
func (*GetPropertiesRequest) MarshalNDR ¶
func (*GetPropertiesRequest) UnmarshalNDR ¶
type GetPropertiesResponse ¶
type GetPropertiesResponse struct {
// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
That *dcom.ORPCThat `idl:"name:That" json:"that"`
Properties *oaut.Dispatch `idl:"name:ppcolProperties" json:"properties"`
// Return: The Properties return value.
Return int32 `idl:"name:Return" json:"return"`
}
GetPropertiesResponse structure represents the Properties operation response
func (*GetPropertiesResponse) MarshalNDR ¶
func (*GetPropertiesResponse) 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.QueueInfo2 `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"`
// WantConnectorType: 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 ConnectorTypeGuid |
// | | property set. |
// +----------------------+----------------------------------------------------------------------------------+
// | VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the |
// | | ConnectorTypeGuid property set. |
// +----------------------+----------------------------------------------------------------------------------+
WantConnectorType *oaut.Variant `idl:"name:WantConnectorType" json:"want_connector_type"`
}
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.Message2 `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 PeekCurrentV1Request ¶
type PeekCurrentV1Request 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"`
}
PeekCurrentV1Request structure represents the PeekCurrent_v1 operation request
func (*PeekCurrentV1Request) MarshalNDR ¶
func (*PeekCurrentV1Request) UnmarshalNDR ¶
type PeekCurrentV1Response ¶
type PeekCurrentV1Response 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_v1 return value.
Return int32 `idl:"name:Return" json:"return"`
}
PeekCurrentV1Response structure represents the PeekCurrent_v1 operation response
func (*PeekCurrentV1Response) MarshalNDR ¶
func (*PeekCurrentV1Response) 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"`
// WantConnectorType: 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 ConnectorTypeGuid |
// | | property set. |
// +----------------------+----------------------------------------------------------------------------------+
// | VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the |
// | | ConnectorTypeGuid property set. |
// +----------------------+----------------------------------------------------------------------------------+
WantConnectorType *oaut.Variant `idl:"name:WantConnectorType" json:"want_connector_type"`
}
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.Message2 `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 PeekNextV1Request ¶
type PeekNextV1Request 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"`
}
PeekNextV1Request structure represents the PeekNext_v1 operation request
func (*PeekNextV1Request) MarshalNDR ¶
func (*PeekNextV1Request) UnmarshalNDR ¶
type PeekNextV1Response ¶
type PeekNextV1Response 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_v1 return value.
Return int32 `idl:"name:Return" json:"return"`
}
PeekNextV1Response structure represents the PeekNext_v1 operation response
func (*PeekNextV1Response) MarshalNDR ¶
func (*PeekNextV1Response) 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"`
// WantConnectorType: 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 ConnectorTypeGuid |
// | | property set. |
// +----------------------+----------------------------------------------------------------------------------+
// | VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the |
// | | ConnectorTypeGuid property set. |
// +----------------------+----------------------------------------------------------------------------------+
WantConnectorType *oaut.Variant `idl:"name:WantConnectorType" json:"want_connector_type"`
}
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.Message2 `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 PeekV1Request ¶
type PeekV1Request 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"`
}
PeekV1Request structure represents the Peek_v1 operation request
func (*PeekV1Request) MarshalNDR ¶
func (*PeekV1Request) UnmarshalNDR ¶
type PeekV1Response ¶
type PeekV1Response 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 IMSMQMessage interface that MUST be set by the
// server with the received message.
Message *mqac.Message `idl:"name:ppmsg" json:"message"`
// Return: The Peek_v1 return value.
Return int32 `idl:"name:Return" json:"return"`
}
PeekV1Response structure represents the Peek_v1 operation response
func (*PeekV1Response) MarshalNDR ¶
func (*PeekV1Response) UnmarshalNDR ¶
type Queue2Client ¶
type Queue2Client 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_v1 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.Head
// and removes it.
//
// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
// error HRESULT on failure.
ReceiveV1(context.Context, *ReceiveV1Request, ...dcerpc.CallOption) (*ReceiveV1Response, error)
// The Peek_v1 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.
PeekV1(context.Context, *PeekV1Request, ...dcerpc.CallOption) (*PeekV1Response, 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_v1 method is received by the server in an RPC_REQUEST packet.
// In response, the server retrieves the Message at the current cursor position in the
// referenced queue's MessagePositionList, removes it, and advances the cursor.
//
// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
// error HRESULT on failure.
ReceiveCurrentV1(context.Context, *ReceiveCurrentV1Request, ...dcerpc.CallOption) (*ReceiveCurrentV1Response, error)
// The PeekNext_v1 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 represented 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.
PeekNextV1(context.Context, *PeekNextV1Request, ...dcerpc.CallOption) (*PeekNextV1Response, error)
// The PeekCurrent_v1 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.
PeekCurrentV1(context.Context, *PeekCurrentV1Request, ...dcerpc.CallOption) (*PeekCurrentV1Response, 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 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)
// Properties operation.
GetProperties(context.Context, *GetPropertiesRequest, ...dcerpc.CallOption) (*GetPropertiesResponse, 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) Queue2Client
}
IMSMQQueue2 interface.
func NewQueue2Client ¶
type Queue2Server ¶
type Queue2Server 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_v1 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.Head
// and removes it.
//
// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
// error HRESULT on failure.
ReceiveV1(context.Context, *ReceiveV1Request) (*ReceiveV1Response, error)
// The Peek_v1 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.
PeekV1(context.Context, *PeekV1Request) (*PeekV1Response, 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_v1 method is received by the server in an RPC_REQUEST packet.
// In response, the server retrieves the Message at the current cursor position in the
// referenced queue's MessagePositionList, removes it, and advances the cursor.
//
// Return Values: The method MUST return S_OK (0x00000000) on success or an implementation-specific
// error HRESULT on failure.
ReceiveCurrentV1(context.Context, *ReceiveCurrentV1Request) (*ReceiveCurrentV1Response, error)
// The PeekNext_v1 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 represented 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.
PeekNextV1(context.Context, *PeekNextV1Request) (*PeekNextV1Response, error)
// The PeekCurrent_v1 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.
PeekCurrentV1(context.Context, *PeekCurrentV1Request) (*PeekCurrentV1Response, 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 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)
// Properties operation.
GetProperties(context.Context, *GetPropertiesRequest) (*GetPropertiesResponse, error)
}
IMSMQQueue2 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"`
// WantConnectorType: 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 ConnectorTypeGuid |
// | | property set. |
// +----------------------+----------------------------------------------------------------------------------+
// | VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the |
// | | ConnectorTypeGuid property set. |
// +----------------------+----------------------------------------------------------------------------------+
WantConnectorType *oaut.Variant `idl:"name:WantConnectorType" json:"want_connector_type"`
}
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.Message2 `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 ReceiveCurrentV1Request ¶
type ReceiveCurrentV1Request 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:
//
// - A VT_DISPATCH or a VT_DISPATCH | VT_BYREF that points to an MSMQTransaction ( b670ebdc-cd6e-4098-a51f-5d4274d8dfdd ) object.
//
// * A VT_I4 that corresponds to one of the MQTRANSACTION ( 3ff1f343-d6e9-4bab-848f-6f2b39209762
// ) (section 2.2.2.1) enumeration values.
//
// If this parameter is not specified by the client, the server ( 3b7be3f7-651c-4f9c-930b-a9a7c4355ad8#gt_434b0234-e970-4e8c-bdfa-e16a30d96703
// ) MUST use the default value MQ_MTS_TRANSACTION (0x00000001) in place of the unspecified
// value.
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 containing 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"`
}
ReceiveCurrentV1Request structure represents the ReceiveCurrent_v1 operation request
func (*ReceiveCurrentV1Request) MarshalNDR ¶
func (*ReceiveCurrentV1Request) UnmarshalNDR ¶
type ReceiveCurrentV1Response ¶
type ReceiveCurrentV1Response 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 IMSMQMessage interface that MUST be set by the
// server with the received message.
Message *mqac.Message `idl:"name:ppmsg" json:"message"`
// Return: The ReceiveCurrent_v1 return value.
Return int32 `idl:"name:Return" json:"return"`
}
ReceiveCurrentV1Response structure represents the ReceiveCurrent_v1 operation response
func (*ReceiveCurrentV1Response) MarshalNDR ¶
func (*ReceiveCurrentV1Response) 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"`
// WantConnectorType: 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 ConnectorTypeGuid |
// | | property set. |
// +----------------------+----------------------------------------------------------------------------------+
// | VARIANT_FALSE 0x0000 | Default. The server MUST return an MSMQMessage object that does not have the |
// | | ConnectorTypeGuid property set. |
// +----------------------+----------------------------------------------------------------------------------+
WantConnectorType *oaut.Variant `idl:"name:WantConnectorType" json:"want_connector_type"`
}
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.Message2 `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 ReceiveV1Request ¶
type ReceiveV1Request 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:
//
// - A VT_DISPATCH or a VT_DISPATCH | VT_BYREF that points to an MSMQTransaction ( b670ebdc-cd6e-4098-a51f-5d4274d8dfdd ) object.
//
// * A VT_I4 that corresponds to one of the MQTRANSACTION (section 2.2.2.1) ( 3ff1f343-d6e9-4bab-848f-6f2b39209762
// ) enumeration values.
//
// If this parameter is not specified by the client, the server ( 3b7be3f7-651c-4f9c-930b-a9a7c4355ad8#gt_434b0234-e970-4e8c-bdfa-e16a30d96703
// ) MUST use the default value MQ_MTS_TRANSACTION (0x00000001) in place of the unspecified
// value.
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 containing 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"`
}
ReceiveV1Request structure represents the Receive_v1 operation request
func (*ReceiveV1Request) MarshalNDR ¶
func (*ReceiveV1Request) UnmarshalNDR ¶
type ReceiveV1Response ¶
type ReceiveV1Response 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 an IMSMQMessage interface pointer that MUST be set by the server
// with the received message.
Message *mqac.Message `idl:"name:ppmsg" json:"message"`
// Return: The Receive_v1 return value.
Return int32 `idl:"name:Return" json:"return"`
}
ReceiveV1Response structure represents the Receive_v1 operation response
func (*ReceiveV1Response) MarshalNDR ¶
func (*ReceiveV1Response) 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 UnimplementedQueue2Server ¶
type UnimplementedQueue2Server struct {
idispatch.UnimplementedDispatchServer
}
Unimplemented IMSMQQueue2
func (UnimplementedQueue2Server) Close ¶
func (UnimplementedQueue2Server) Close(context.Context, *CloseRequest) (*CloseResponse, error)
func (UnimplementedQueue2Server) EnableNotification ¶
func (UnimplementedQueue2Server) EnableNotification(context.Context, *EnableNotificationRequest) (*EnableNotificationResponse, error)
func (UnimplementedQueue2Server) GetAccess ¶
func (UnimplementedQueue2Server) GetAccess(context.Context, *GetAccessRequest) (*GetAccessResponse, error)
func (UnimplementedQueue2Server) GetHandle ¶
func (UnimplementedQueue2Server) GetHandle(context.Context, *GetHandleRequest) (*GetHandleResponse, error)
func (UnimplementedQueue2Server) GetIsOpen ¶
func (UnimplementedQueue2Server) GetIsOpen(context.Context, *GetIsOpenRequest) (*GetIsOpenResponse, error)
func (UnimplementedQueue2Server) GetProperties ¶
func (UnimplementedQueue2Server) GetProperties(context.Context, *GetPropertiesRequest) (*GetPropertiesResponse, error)
func (UnimplementedQueue2Server) GetQueueInfo ¶
func (UnimplementedQueue2Server) GetQueueInfo(context.Context, *GetQueueInfoRequest) (*GetQueueInfoResponse, error)
func (UnimplementedQueue2Server) GetShareMode ¶
func (UnimplementedQueue2Server) GetShareMode(context.Context, *GetShareModeRequest) (*GetShareModeResponse, error)
func (UnimplementedQueue2Server) Peek ¶
func (UnimplementedQueue2Server) Peek(context.Context, *PeekRequest) (*PeekResponse, error)
func (UnimplementedQueue2Server) PeekCurrent ¶
func (UnimplementedQueue2Server) PeekCurrent(context.Context, *PeekCurrentRequest) (*PeekCurrentResponse, error)
func (UnimplementedQueue2Server) PeekCurrentV1 ¶
func (UnimplementedQueue2Server) PeekCurrentV1(context.Context, *PeekCurrentV1Request) (*PeekCurrentV1Response, error)
func (UnimplementedQueue2Server) PeekNext ¶
func (UnimplementedQueue2Server) PeekNext(context.Context, *PeekNextRequest) (*PeekNextResponse, error)
func (UnimplementedQueue2Server) PeekNextV1 ¶
func (UnimplementedQueue2Server) PeekNextV1(context.Context, *PeekNextV1Request) (*PeekNextV1Response, error)
func (UnimplementedQueue2Server) PeekV1 ¶
func (UnimplementedQueue2Server) PeekV1(context.Context, *PeekV1Request) (*PeekV1Response, error)
func (UnimplementedQueue2Server) Receive ¶
func (UnimplementedQueue2Server) Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
func (UnimplementedQueue2Server) ReceiveCurrent ¶
func (UnimplementedQueue2Server) ReceiveCurrent(context.Context, *ReceiveCurrentRequest) (*ReceiveCurrentResponse, error)
func (UnimplementedQueue2Server) ReceiveCurrentV1 ¶
func (UnimplementedQueue2Server) ReceiveCurrentV1(context.Context, *ReceiveCurrentV1Request) (*ReceiveCurrentV1Response, error)
func (UnimplementedQueue2Server) ReceiveV1 ¶
func (UnimplementedQueue2Server) ReceiveV1(context.Context, *ReceiveV1Request) (*ReceiveV1Response, error)
func (UnimplementedQueue2Server) Reset ¶
func (UnimplementedQueue2Server) Reset(context.Context, *ResetRequest) (*ResetResponse, error)