Message 생성자
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
Message 클래스의 새 인스턴스를 초기화합니다.
오버로드
| Name | Description |
|---|---|
| Message() |
빈 본문을 사용하여 클래스의 Message 새 인스턴스를 초기화합니다. |
| Message(Object) |
지정된 개체를 메시지 본 Message 문으로 serialize하는 데 사용하여 XmlMessageFormatter 클래스의 새 인스턴스를 초기화합니다. |
| Message(Object, IMessageFormatter) |
지정된 포맷터를 사용하여 지정된 개체를 Message 메시지 본문으로 serialize하여 클래스의 새 인스턴스를 초기화합니다. |
Message()
빈 본문을 사용하여 클래스의 Message 새 인스턴스를 초기화합니다.
public:
Message();
public Message();
Public Sub New ()
예제
다음 코드 예제에서는 서로 다른 우선 순위의 두 메시지를 큐에 보내고 이후에 검색합니다.
#using <system.dll>
#using <system.messaging.dll>
using namespace System;
using namespace System::Messaging;
/// <summary>
/// Provides a container class for the example.
/// </summary>
ref class MyNewQueue
{
//**************************************************
// Sends a string message to a queue.
//**************************************************
public:
void SendMessage( MessagePriority priority, String^ messageBody )
{
// Connect to a queue on the local computer.
MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
// Create a new message.
Message^ myMessage = gcnew Message;
if ( priority > MessagePriority::Normal )
{
myMessage->Body = "High Priority: {0}",messageBody;
}
else
{
myMessage->Body = messageBody;
}
// Set the priority of the message.
myMessage->Priority = priority;
// Send the Order to the queue.
myQueue->Send( myMessage );
return;
}
//**************************************************
// Receives a message.
//**************************************************
void ReceiveMessage()
{
// Connect to the a queue on the local computer.
MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
// Set the queue to read the priority. By default, it
// is not read.
myQueue->MessageReadPropertyFilter->Priority = true;
// Set the formatter to indicate body contains a String^.
array<Type^>^ p = gcnew array<Type^>(1);
p[ 0 ] = String::typeid;
myQueue->Formatter = gcnew XmlMessageFormatter( p );
try
{
// Receive and format the message.
Message^ myMessage = myQueue->Receive();
// Display message information.
Console::WriteLine( "Priority: {0}",
myMessage->Priority );
Console::WriteLine( "Body: {0}",
myMessage->Body );
}
catch ( MessageQueueException^ )
{
// Handle Message Queuing exceptions.
}
// Handle invalid serialization format.
catch ( InvalidOperationException^ e )
{
Console::WriteLine( e->Message );
}
// Catch other exceptions as necessary.
return;
}
};
//**************************************************
// Provides an entry point into the application.
//
// This example sends and receives a message from
// a queue.
//**************************************************
int main()
{
// Create a new instance of the class.
MyNewQueue^ myNewQueue = gcnew MyNewQueue;
// Send messages to a queue.
myNewQueue->SendMessage( MessagePriority::Normal, "First Message Body." );
myNewQueue->SendMessage( MessagePriority::Highest, "Second Message Body." );
// Receive messages from a queue.
myNewQueue->ReceiveMessage();
myNewQueue->ReceiveMessage();
return 0;
}
using System;
using System.Messaging;
namespace MyProject
{
/// <summary>
/// Provides a container class for the example.
/// </summary>
public class MyNewQueue
{
//**************************************************
// Provides an entry point into the application.
//
// This example sends and receives a message from
// a queue.
//**************************************************
public static void Main()
{
// Create a new instance of the class.
MyNewQueue myNewQueue = new MyNewQueue();
// Send messages to a queue.
myNewQueue.SendMessage(MessagePriority.Normal, "First Message Body.");
myNewQueue.SendMessage(MessagePriority.Highest, "Second Message Body.");
// Receive messages from a queue.
myNewQueue.ReceiveMessage();
myNewQueue.ReceiveMessage();
return;
}
//**************************************************
// Sends a string message to a queue.
//**************************************************
public void SendMessage(MessagePriority priority, string messageBody)
{
// Connect to a queue on the local computer.
MessageQueue myQueue = new MessageQueue(".\\myQueue");
// Create a new message.
Message myMessage = new Message();
if(priority > MessagePriority.Normal)
{
myMessage.Body = "High Priority: " + messageBody;
}
else
{
myMessage.Body = messageBody;
}
// Set the priority of the message.
myMessage.Priority = priority;
// Send the Order to the queue.
myQueue.Send(myMessage);
return;
}
//**************************************************
// Receives a message.
//**************************************************
public void ReceiveMessage()
{
// Connect to the a queue on the local computer.
MessageQueue myQueue = new MessageQueue(".\\myQueue");
// Set the queue to read the priority. By default, it
// is not read.
myQueue.MessageReadPropertyFilter.Priority = true;
// Set the formatter to indicate body contains a string.
myQueue.Formatter = new XmlMessageFormatter(new Type[]
{typeof(string)});
try
{
// Receive and format the message.
Message myMessage = myQueue.Receive();
// Display message information.
Console.WriteLine("Priority: " +
myMessage.Priority.ToString());
Console.WriteLine("Body: " +
myMessage.Body.ToString());
}
catch (MessageQueueException)
{
// Handle Message Queuing exceptions.
}
// Handle invalid serialization format.
catch (InvalidOperationException e)
{
Console.WriteLine(e.Message);
}
// Catch other exceptions as necessary.
return;
}
}
}
Imports System.Messaging
'Provides a container class for the example.
Public Class MyNewQueue
' Provides an entry point into the application.
'
' This example sends and receives a message from
' a queue.
Public Shared Sub Main()
' Create a new instance of the class.
Dim myNewQueue As New MyNewQueue()
' Send messages to a queue.
myNewQueue.SendMessage(MessagePriority.Normal, "First Message Body.")
myNewQueue.SendMessage(MessagePriority.Highest, "Second Message Body.")
' Receive messages from a queue.
myNewQueue.ReceiveMessage()
myNewQueue.ReceiveMessage()
Return
End Sub
' Sends a string message to a queue.
Public Sub SendMessage(priority As MessagePriority, messageBody As String)
' Connect to a queue on the local computer.
Dim myQueue As New MessageQueue(".\myQueue")
' Create a new message.
Dim myMessage As New Message()
If priority > MessagePriority.Normal Then
myMessage.Body = "High Priority: " + messageBody
Else
myMessage.Body = messageBody
End If
' Set the priority of the message.
myMessage.Priority = priority
' Send the Order to the queue.
myQueue.Send(myMessage)
Return
End Sub
' Receives a message.
Public Sub ReceiveMessage()
' Connect to the a queue on the local computer.
Dim myQueue As New MessageQueue(".\myQueue")
' Set the queue to read the priority. By default, it
' is not read.
myQueue.MessageReadPropertyFilter.Priority = True
' Set the formatter to indicate body contains a string.
myQueue.Formatter = New XmlMessageFormatter(New Type() {GetType(String)})
Try
' Receive and format the message.
Dim myMessage As Message = myQueue.Receive()
' Display message information.
Console.WriteLine(("Priority: " + myMessage.Priority.ToString()))
Console.WriteLine(("Body: " + myMessage.Body.ToString()))
' Handle invalid serialization format.
Catch e As InvalidOperationException
Console.WriteLine(e.Message)
End Try
' Catch other exceptions as necessary.
Return
End Sub
End Class
설명
이 오버로드를 사용하여 빈 본문이 있는 클래스의 Message 새 인스턴스를 만듭니다.
개체를 Body 보내기 전에 속성 또는 BodyStream 속성을 지정합니다 Message . 속성은 Body 텍스트 문자열, 구조체 개체, 클래스 인스턴스 또는 포함된 개체와 같이 serialize할 수 있는 모든 개체일 수 있습니다.
메시지 내용을 속성에 직접 BodyStream 쓰지 않는 한 메시지를 보내기 전에 속성을 설정합니다 Formatter . 본문은 인스턴스에서 메서드가 Formatter 호출 MessageQueue 될 때 Send 속성 값을 사용하여 serialize됩니다.
XmlMessageFormatter 느슨하게 결합되므로 이 형식을 사용할 때 보낸 사람 및 수신자에 동일한 개체 형식을 가질 필요가 없습니다. BinaryMessageFormatter 데이터를 이 ActiveXMessageFormatter 진 표현으로 직렬화합니다. COM ActiveXMessageFormatter 구성 요소를 보내거나 받을 때 사용됩니다.
다음 표에서는 인스턴스에 대한 초기 속성 값을 보여 줍니다 Message.
| 재산 | 초기 값 |
|---|---|
| AcknowledgeType | AcknowledgeType.None |
| AdministrationQueue | null |
| AppSpecific | 0 |
| AttachSenderId | true |
| AuthenticationProviderName | Microsoft 기본 암호화 공급자 버전 1.0 |
| AuthenticationProviderType | CryptoProviderType.RSA_FULL |
| Body | null |
| BodyStream | Stream.null |
| BodyType | 0 |
| ConnectorType | Guid.Empty |
| CorrelationId | 빈 문자열("") |
| DestinationSymmetricKey | 길이가 0인 바이트 배열 |
| DigitalSignature | 길이가 0인 바이트 배열 |
| EncryptionAlgorithm | EncryptionAlgorithm.RC2 |
| Extension | 길이가 0인 바이트 배열 |
| Formatter | XmlMessageFormatter |
| HashAlgorithm | HashAlgorithm.MD5 |
| Label | 빈 문자열("") |
| Priority | MessagePriority.Normal |
| Recoverable | false |
| ResponseQueue | null |
| SenderCertificate | 길이가 0인 바이트 배열 |
| TimeToBeReceived | Message.InfiniteTimeout |
| TimeToReachQueue | Message.InfiniteTimeout |
| TransactionStatusQueue | null |
| UseAuthentication | false |
| UseDeadLetterQueue | false |
| UseEncryption | false |
| UseJournalQueue | false |
| UseTracing | false |
추가 정보
적용 대상
Message(Object)
지정된 개체를 메시지 본 Message 문으로 serialize하는 데 사용하여 XmlMessageFormatter 클래스의 새 인스턴스를 초기화합니다.
public:
Message(System::Object ^ body);
public Message(object body);
new System.Messaging.Message : obj -> System.Messaging.Message
Public Sub New (body As Object)
매개 변수
- body
- Object
메시지 본문으로 serialize할 개체입니다.
예제
다음 코드 예제에서는 새 큐를 만들고 주문이 포함된 메시지를 보낸 다음 검색합니다.
#using <system.dll>
#using <system.messaging.dll>
#using <system.drawing.dll>
using namespace System;
using namespace System::Messaging;
using namespace System::Drawing;
using namespace System::IO;
ref class Order
{
public:
int orderId;
DateTime orderTime;
};
ref class MyNewQueue
{
public:
static void CreateQueue( String^ queuePath )
{
try
{
if ( !MessageQueue::Exists( queuePath ) )
{
MessageQueue::Create( queuePath );
}
else
{
Console::WriteLine( "{0} already exists.", queuePath );
}
}
catch ( MessageQueueException^ e )
{
Console::WriteLine( e->Message );
}
}
void SendMessage()
{
try
{
// Create a new order and set values.
Order^ sentOrder = gcnew Order;
sentOrder->orderId = 3;
sentOrder->orderTime = DateTime::Now;
// Connect to a queue on the local computer.
MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
// Create the new order.
Message^ myMessage = gcnew Message( sentOrder );
// Send the order to the queue.
myQueue->Send( myMessage );
}
catch ( ArgumentException^ e )
{
Console::WriteLine( e->Message );
}
return;
}
void ReceiveMessage()
{
// Connect to the a queue on the local computer.
MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
// Set the formatter to indicate body contains an Order.
array<Type^>^p = gcnew array<Type^>(1);
p[ 0 ] = Order::typeid;
myQueue->Formatter = gcnew XmlMessageFormatter( p );
try
{
// Receive and format the message.
Message^ myMessage = myQueue->Receive();
Order^ myOrder = dynamic_cast<Order^>(myMessage->Body);
// Display message information.
Console::WriteLine( "Order ID: {0}", myOrder->orderId );
Console::WriteLine( "Sent: {0}", myOrder->orderTime );
}
catch ( MessageQueueException^ )
{
// Handle Message Queuing exceptions.
}
// Handle invalid serialization format.
catch ( InvalidOperationException^ e )
{
Console::WriteLine( e->Message );
}
// Catch other exceptions as necessary.
return;
}
};
int main()
{
// Create a new instance of the class.
MyNewQueue^ myNewQueue = gcnew MyNewQueue;
// Create a queue on the local computer.
MyNewQueue::CreateQueue( ".\\myQueue" );
// Send a message to a queue.
myNewQueue->SendMessage();
// Receive a message from a queue.
myNewQueue->ReceiveMessage();
return 0;
}
using System;
using System.Messaging;
using System.Drawing;
using System.IO;
namespace MyProject
{
// The following example
// sends to a queue and receives from a queue.
public class Order
{
public int orderId;
public DateTime orderTime;
};
/// <summary>
/// Provides a container class for the example.
/// </summary>
public class MyNewQueue
{
//**************************************************
// Provides an entry point into the application.
//
// This example sends and receives a message from
// a queue.
//**************************************************
public static void Main()
{
// Create a new instance of the class.
MyNewQueue myNewQueue = new MyNewQueue();
// Create a queue on the local computer.
CreateQueue(".\\myQueue");
// Send a message to a queue.
myNewQueue.SendMessage();
// Receive a message from a queue.
myNewQueue.ReceiveMessage();
return;
}
//**************************************************
// Creates a new queue.
//**************************************************
public static void CreateQueue(string queuePath)
{
try
{
if(!MessageQueue.Exists(queuePath))
{
MessageQueue.Create(queuePath);
}
else
{
Console.WriteLine(queuePath + " already exists.");
}
}
catch (MessageQueueException e)
{
Console.WriteLine(e.Message);
}
}
//**************************************************
// Sends an Order to a queue.
//**************************************************
public void SendMessage()
{
try
{
// Create a new order and set values.
Order sentOrder = new Order();
sentOrder.orderId = 3;
sentOrder.orderTime = DateTime.Now;
// Connect to a queue on the local computer.
MessageQueue myQueue = new MessageQueue(".\\myQueue");
// Create the new order.
Message myMessage = new Message(sentOrder);
// Send the order to the queue.
myQueue.Send(myMessage);
}
catch(ArgumentException e)
{
Console.WriteLine(e.Message);
}
return;
}
//**************************************************
// Receives a message containing an order.
//**************************************************
public void ReceiveMessage()
{
// Connect to the a queue on the local computer.
MessageQueue myQueue = new MessageQueue(".\\myQueue");
// Set the formatter to indicate body contains an Order.
myQueue.Formatter = new XmlMessageFormatter(new Type[]
{typeof(MyProject.Order)});
try
{
// Receive and format the message.
Message myMessage = myQueue.Receive();
Order myOrder = (Order)myMessage.Body;
// Display message information.
Console.WriteLine("Order ID: " +
myOrder.orderId.ToString());
Console.WriteLine("Sent: " +
myOrder.orderTime.ToString());
}
catch (MessageQueueException)
{
// Handle Message Queuing exceptions.
}
// Handle invalid serialization format.
catch (InvalidOperationException e)
{
Console.WriteLine(e.Message);
}
// Catch other exceptions as necessary.
return;
}
}
}
Imports System.Messaging
Imports System.Drawing
Imports System.IO
' The following example
' sends to a queue and receives from a queue.
Public Class Order
Public orderId As Integer
Public orderTime As DateTime
End Class
' Provides a container class for the example.
Public Class MyNewQueue
' Provides an entry point into the application.
'
' This example sends and receives a message from
' a queue.
Public Shared Sub Main()
' Create a new instance of the class.
Dim myNewQueue As New MyNewQueue()
' Create a queue on the local computer.
CreateQueue(".\myQueue")
' Send a message to a queue.
myNewQueue.SendMessage()
' Receive a message from a queue.
myNewQueue.ReceiveMessage()
Return
End Sub
' Creates a new queue.
Public Shared Sub CreateQueue(queuePath As String)
Try
If Not MessageQueue.Exists(queuePath) Then
MessageQueue.Create(queuePath)
Else
Console.WriteLine((queuePath + " already exists."))
End If
Catch e As MessageQueueException
Console.WriteLine(e.Message)
End Try
End Sub
' Sends an Order to a queue.
Public Sub SendMessage()
Try
' Create a new order and set values.
Dim sentOrder As New Order()
sentOrder.orderId = 3
sentOrder.orderTime = DateTime.Now
' Connect to a queue on the local computer.
Dim myQueue As New MessageQueue(".\myQueue")
' Create the new order.
Dim myMessage As New Message(sentOrder)
' Send the order to the queue.
myQueue.Send(myMessage)
Catch e As ArgumentException
Console.WriteLine(e.Message)
End Try
Return
End Sub
' Receives a message containing an order.
Public Sub ReceiveMessage()
' Connect to the a queue on the local computer.
Dim myQueue As New MessageQueue(".\myQueue")
' Set the formatter to indicate body contains an Order.
myQueue.Formatter = New XmlMessageFormatter(New Type() {GetType(Order)})
Try
' Receive and format the message.
Dim myMessage As Message = myQueue.Receive()
Dim myOrder As Order = CType(myMessage.Body, Order)
' Display message information.
Console.WriteLine(("Order ID: " + myOrder.orderId.ToString()))
Console.WriteLine(("Sent: " + myOrder.orderTime.ToString()))
' Handle invalid serialization format.
Catch e As InvalidOperationException
Console.WriteLine(e.Message)
End Try
' Catch other exceptions as necessary.
Return
End Sub
End Class
설명
이 오버로드를 사용하여 매개 변수로 지정된 클래스의 Message 새 인스턴스를 Bodybody 만듭니다. 매개 변수는 body 텍스트 문자열, 구조체 개체, 클래스 인스턴스 또는 포함된 개체와 같이 serialize할 수 있는 모든 개체일 수 있습니다. 본문은 전송되기 전에 Message 속성을 변경하지 Formatter 않는 한 해당 본문을 사용하여 XmlMessageFormatter 직렬화됩니다. 호출Send하기 전에 언제든지 또는 Formatter 속성을 변경 Body 하면 새 속성 값에 따라 메시지가 serialize됩니다.
XmlMessageFormatter 느슨하게 결합되므로 이 형식을 사용할 때 보낸 사람 및 수신자에 동일한 개체 형식을 가질 필요가 없습니다. BinaryMessageFormatter 데이터를 이 ActiveXMessageFormatter 진 표현으로 직렬화합니다. COM ActiveXMessageFormatter 구성 요소를 보내거나 받을 때 사용됩니다.
다음 표에서는 인스턴스에 대한 초기 속성 값을 보여 줍니다 Message.
| 재산 | 초기 값 |
|---|---|
| AcknowledgeType | AcknowledgeType.None |
| AdministrationQueue | null |
| AppSpecific | 0 |
| AttachSenderId | true |
| AuthenticationProviderName | Microsoft 기본 암호화 공급자 버전 1.0 |
| AuthenticationProviderType | CryptoProviderType.RSA_FULL |
| Body | 매개 변수입니다 body . |
| BodyStream | Stream.null |
| BodyType | 0 |
| ConnectorType | Guid.Empty |
| CorrelationId | 빈 문자열("") |
| DestinationSymmetricKey | 길이가 0인 바이트 배열 |
| DigitalSignature | 길이가 0인 바이트 배열 |
| EncryptionAlgorithm | EncryptionAlgorithm.RC2 |
| Extension | 길이가 0인 바이트 배열 |
| Formatter | XmlMessageFormatter |
| HashAlgorithm | HashAlgorithm.MD5 |
| Label | 빈 문자열("") |
| Priority | MessagePriority.Normal |
| Recoverable | false |
| ResponseQueue | null |
| SenderCertificate | 길이가 0인 바이트 배열 |
| TimeToBeReceived | Message.InfiniteTimeout |
| TimeToReachQueue | Message.InfiniteTimeout |
| TransactionStatusQueue | null |
| UseAuthentication | false |
| UseDeadLetterQueue | false |
| UseEncryption | false |
| UseJournalQueue | false |
| UseTracing | false |
추가 정보
적용 대상
Message(Object, IMessageFormatter)
지정된 포맷터를 사용하여 지정된 개체를 Message 메시지 본문으로 serialize하여 클래스의 새 인스턴스를 초기화합니다.
public:
Message(System::Object ^ body, System::Messaging::IMessageFormatter ^ formatter);
public Message(object body, System.Messaging.IMessageFormatter formatter);
new System.Messaging.Message : obj * System.Messaging.IMessageFormatter -> System.Messaging.Message
Public Sub New (body As Object, formatter As IMessageFormatter)
매개 변수
- body
- Object
메시지 본문으로 serialize할 개체입니다.
- formatter
- IMessageFormatter
IMessageFormatter 메시지 본문을 serialize할 포맷터를 지정하는 A입니다.
예제
using System;
using System.Messaging;
using System.Drawing;
using System.IO;
namespace MyProject
{
/// <summary>
/// Provides a container class for the example.
/// </summary>
public class MyNewQueue
{
//**************************************************
// Provides an entry point into the application.
//
// This example sends and receives a message from
// a queue.
//**************************************************
public static void Main()
{
// Create a new instance of the class.
MyNewQueue myNewQueue = new MyNewQueue();
// Create a queue on the local computer.
CreateQueue(".\\myQueue");
// Send a message to a queue.
myNewQueue.SendMessage();
// Receive a message from a queue.
myNewQueue.ReceiveMessage();
return;
}
//**************************************************
// Creates a new queue.
//**************************************************
public static void CreateQueue(string queuePath)
{
try
{
if(!MessageQueue.Exists(queuePath))
{
MessageQueue.Create(queuePath);
}
else
{
Console.WriteLine(queuePath + " already exists.");
}
}
catch (MessageQueueException e)
{
Console.WriteLine(e.Message);
}
}
//**************************************************
// Sends an image to a queue, using the BinaryMessageFormatter.
//**************************************************
public void SendMessage()
{
try{
// Create a new bitmap.
// The file must be in the \bin\debug or \bin\retail folder, or
// you must give a full path to its location.
Image myImage = Bitmap.FromFile("SentImage.bmp");
// Connect to a queue on the local computer.
MessageQueue myQueue = new MessageQueue(".\\myQueue");
Message myMessage = new Message(myImage, new BinaryMessageFormatter());
// Send the image to the queue.
myQueue.Send(myMessage);
}
catch(ArgumentException e)
{
Console.WriteLine(e.Message);
}
return;
}
//**************************************************
// Receives a message containing an image.
//**************************************************
public void ReceiveMessage()
{
try
{
// Connect to the a queue on the local computer.
MessageQueue myQueue = new MessageQueue(".\\myQueue");
// Set the formatter to indicate body contains an Order.
myQueue.Formatter = new BinaryMessageFormatter();
// Receive and format the message.
System.Messaging.Message myMessage = myQueue.Receive();
Bitmap myImage = (Bitmap)myMessage.Body;
// This will be saved in the \bin\debug or \bin\retail folder.
myImage.Save("ReceivedImage.bmp",System.Drawing.Imaging.ImageFormat.Bmp);
}
catch (MessageQueueException)
{
// Handle Message Queuing exceptions.
}
// Handle invalid serialization format.
catch (InvalidOperationException e)
{
Console.WriteLine(e.Message);
}
catch (IOException e)
{
// Handle file access exceptions.
}
// Catch other exceptions as necessary.
return;
}
}
}
Imports System.Messaging
Imports System.Drawing
Imports System.IO
Namespace MyProj
_
Public Class MyNewQueue
'**************************************************
' Provides an entry point into the application.
'
' This example sends and receives a message from
' a queue.
'**************************************************
Public Shared Sub Main()
' Create a new instance of the class.
Dim myNewQueue As New MyNewQueue()
' Create a queue on the local computer.
CreateQueue(".\myQueue")
' Send a message to a queue.
myNewQueue.SendMessage()
' Receive a message from a queue.
myNewQueue.ReceiveMessage()
Return
End Sub
'**************************************************
' Creates a new queue.
'**************************************************
Public Shared Sub CreateQueue(queuePath As String)
Try
If Not MessageQueue.Exists(queuePath) Then
MessageQueue.Create(queuePath)
Else
Console.WriteLine((queuePath + " already exists."))
End If
Catch e As MessageQueueException
Console.WriteLine(e.Message)
End Try
End Sub
'**************************************************
' Sends an image to a queue, using the BinaryMessageFormatter.
'**************************************************
Public Sub SendMessage()
Try
' Create a new bitmap.
' The file must be in the \bin\debug or \bin\retail folder, or
' you must give a full path to its location.
Dim myImage As Image = Bitmap.FromFile("SentImage.bmp")
' Connect to a queue on the local computer.
Dim myQueue As New MessageQueue(".\myQueue")
Dim myMessage As New Message(myImage, New BinaryMessageFormatter())
' Send the image to the queue.
myQueue.Send(myMessage)
Catch e As ArgumentException
Console.WriteLine(e.Message)
End Try
Return
End Sub
'**************************************************
' Receives a message containing an image.
'**************************************************
Public Sub ReceiveMessage()
Try
' Connect to the a queue on the local computer.
Dim myQueue As New MessageQueue(".\myQueue")
' Set the formatter to indicate body contains an Order.
myQueue.Formatter = New BinaryMessageFormatter()
' Receive and format the message.
Dim myMessage As System.Messaging.Message = myQueue.Receive()
Dim myImage As Bitmap = CType(myMessage.Body, Bitmap)
' This will be saved in the \bin\debug or \bin\retail folder.
myImage.Save("ReceivedImage.bmp", System.Drawing.Imaging.ImageFormat.Bmp)
'Catch
' Handle Message Queuing exceptions.
' Handle invalid serialization format.
Catch e As InvalidOperationException
Console.WriteLine(e.Message)
Catch e As IOException
End Try
' Handle file access exceptions.
' Catch other exceptions as necessary.
Return
End Sub
End Class
End Namespace 'MyProj
설명
이 오버로드를 사용하여 매개 변수에서 지정 body 하고 유효한 포맷터를 사용하여 본문을 serialize하는 클래스 Body 의 Message 새 인스턴스를 만듭니다.
body 매개 변수는 텍스트 문자열, 구조체 개체, 클래스 인스턴스 또는 포함된 개체와 같이 serialize할 수 있는 모든 개체입니다. 호출Send하기 전에 언제든지 또는 Formatter 속성을 변경 Body 하면 새 속성 값에 따라 메시지가 serialize됩니다.
XmlMessageFormatter 느슨하게 결합되므로 이 형식을 사용할 때 보낸 사람 및 수신자에 동일한 개체 형식을 가질 필요가 없습니다. BinaryMessageFormatter 데이터를 이 ActiveXMessageFormatter 진 표현으로 직렬화합니다. COM ActiveXMessageFormatter 구성 요소를 보내거나 받을 때 사용됩니다.
다음 표에서는 인스턴스에 대한 초기 속성 값을 보여 줍니다 Message.
| 재산 | 초기 값 |
|---|---|
| AcknowledgeType | AcknowledgeType.None |
| AdministrationQueue | null |
| AppSpecific | 0 |
| AttachSenderId | true |
| AuthenticationProviderName | Microsoft 기본 암호화 공급자 버전 1.0 |
| AuthenticationProviderType | CryptoProviderType.RSA_FULL |
| Body | 매개 변수입니다 body . |
| BodyStream | Stream.null |
| BodyType | 0 |
| ConnectorType | Guid.Empty |
| CorrelationId | 빈 문자열("") |
| DestinationSymmetricKey | 길이가 0인 바이트 배열 |
| DigitalSignature | 길이가 0인 바이트 배열 |
| EncryptionAlgorithm | EncryptionAlgorithm.RC2 |
| Extension | 길이가 0인 바이트 배열 |
| Formatter | 매개 변수입니다 formatter . |
| HashAlgorithm | HashAlgorithm.MD5 |
| Label | 빈 문자열("") |
| Priority | MessagePriority.Normal |
| Recoverable | false |
| ResponseQueue | null |
| SenderCertificate | 길이가 0인 바이트 배열 |
| TimeToBeReceived | Message.InfiniteTimeout |
| TimeToReachQueue | Message.InfiniteTimeout |
| TransactionStatusQueue | null |
| UseAuthentication | false |
| UseDeadLetterQueue | false |
| UseEncryption | false |
| UseJournalQueue | false |
| UseTracing | false |
추가 정보
- XmlMessageFormatter
- BinaryMessageFormatter
- ActiveXMessageFormatter
- DefaultPropertiesToSend
- MessageQueue
- Send(Object)
- Peek()
- Receive()