system.messaging.cs

研讀原始碼的好工具

     String get_Path();
     Void set_Path( String value);
     Class System.Messaging.Interop.QueuePropertyVariants get_Properties();
     Class QueuePropertyFilter get_PropertyFilter();
     String get_QueueName();
     Void set_QueueName( String value);
     String get_QueuePath();
     I get_ReadHandle();
     Class System.ComponentModel.ISynchronizeInvoke get_SynchronizingObject();
     Void set_SynchronizingObject( Class System.ComponentModel.ISynchronizeInvoke value);
     Boolean get_Transactional();
     Boolean get_UseJournalQueue();
     Void set_UseJournalQueue( Boolean value);
     I get_WriteHandle();
     Void add_PeekCompleted( Class System.Messaging.PeekCompletedEventHandler value);
     Void remove_PeekCompleted( Class System.Messaging.PeekCompletedEventHandler value);
     Void add_ReceiveCompleted( Class System.Messaging.ReceiveCompletedEventHandler value);
     Void remove_ReceiveCompleted( Class System.Messaging.ReceiveCompletedEventHandler value);
     Class System.IAsyncResult BeginPeek();
     Class System.IAsyncResult BeginPeek( ValueClass System.TimeSpan timeout);
     Class System.IAsyncResult BeginPeek( ValueClass System.TimeSpan timeout,  Object stateObject);
     Class System.IAsyncResult BeginPeek( ValueClass System.TimeSpan timeout,  Object stateObject,  Class System.AsyncCallback callback);
     Class System.IAsyncResult BeginReceive();
     Class System.IAsyncResult BeginReceive( ValueClass System.TimeSpan timeout);
     Class System.IAsyncResult BeginReceive( ValueClass System.TimeSpan timeout,  Object stateObject);
     Class System.IAsyncResult BeginReceive( ValueClass System.TimeSpan timeout,  Object stateObject,  Class System.AsyncCallback callback);
     Void ClearConnectionCache();
     Void Close();
     Class System.Messaging.MessageQueue Create( String path);
     Class System.Messaging.MessageQueue Create( String path,  Boolean transactional);
     SZArray Class System.Messaging.MessageQueue CreateMessageQueuesSnapshot( Class System.Messaging.MessageQueueCriteria criteria);
     SZArray Class System.Messaging.MessageQueue CreateMessageQueuesSnapshot( Class System.Messaging.MessageQueueCriteria criteria,  Boolean checkSecurity);
     Void Delete( String path);
     Void Dispose( Boolean disposing);
     Class System.Messaging.Message EndPeek( Class System.IAsyncResult asyncResult);
     Class System.Messaging.Message EndReceive( Class System.IAsyncResult asyncResult);
     Boolean Exists( String path);
     Void GenerateQueueProperties();
     SZArray Class System.Messaging.Message GetAllMessages();
     Class System.Collections.IEnumerator GetEnumerator();
     ValueClass System.Guid GetMachineId( String machineName);
     Class System.Messaging.MessageQueueEnumerator GetMessageQueueEnumerator();
     Class System.Messaging.MessageQueueEnumerator GetMessageQueueEnumerator( Class System.Messaging.MessageQueueCriteria criteria);
     Class System.Messaging.MessageQueueEnumerator GetMessageQueueEnumerator( Class System.Messaging.MessageQueueCriteria criteria,  Boolean checkSecurity);
     Class System.Messaging.MessageEnumerator GetMessageEnumerator();
     SZArray Class System.Messaging.MessageQueue GetPrivateQueuesByMachine( String machineName);
     SZArray Class System.Messaging.MessageQueue GetPublicQueues();
     SZArray Class System.Messaging.MessageQueue GetPublicQueues( Class System.Messaging.MessageQueueCriteria criteria);
     SZArray Class System.Messaging.MessageQueue GetPublicQueuesByCategory( ValueClass System.Guid category);
     SZArray Class System.Messaging.MessageQueue GetPublicQueuesByLabel( String label);
     SZArray Class System.Messaging.MessageQueue GetPublicQueuesByLabel( String label,  Boolean checkSecurity);
     SZArray Class System.Messaging.MessageQueue GetPublicQueuesByMachine( String machineName);
     Boolean IsCanonicalPath( String path,  Boolean checkQueueNameSize);
     Boolean IsFatalError( I4 value);
     Boolean IsMemoryError( I4 value);
     Void OnRequestCompleted( Class System.IAsyncResult asyncResult);
     Class System.Messaging.Message Peek();
     Class System.Messaging.Message Peek( ValueClass System.TimeSpan timeout);
     Class System.Messaging.Message PeekById( String id);
     Class System.Messaging.Message PeekById( String id,  ValueClass System.TimeSpan timeout);
     Class System.Messaging.Message PeekByCorrelationId( String correlationId);
     Class System.Messaging.Message PeekByCorrelationId( String correlationId,  ValueClass System.TimeSpan timeout);
     Void Purge();
     Class System.Messaging.Message Receive();
     Class System.Messaging.Message Receive( Class System.Messaging.MessageQueueTransaction transaction);
     Class System.Messaging.Message Receive( ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.Message Receive( ValueClass System.TimeSpan timeout);
     Class System.Messaging.Message Receive( ValueClass System.TimeSpan timeout,  Class System.Messaging.MessageQueueTransaction transaction);
     Class System.Messaging.Message Receive( ValueClass System.TimeSpan timeout,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.IAsyncResult ReceiveAsync( ValueClass System.TimeSpan timeout,  I4 action,  Class System.AsyncCallback callback,  Object stateObject);
     Class System.Messaging.Message ReceiveBy( String id,  ValueClass System.TimeSpan timeout,  Boolean remove,  Boolean compareId,  Boolean throwTimeout,  Class System.Messaging.MessageQueueTransaction transaction,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.Message ReceiveById( String id);
     Class System.Messaging.Message ReceiveById( String id,  Class System.Messaging.MessageQueueTransaction transaction);
     Class System.Messaging.Message ReceiveById( String id,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.Message ReceiveById( String id,  ValueClass System.TimeSpan timeout);
     Class System.Messaging.Message ReceiveById( String id,  ValueClass System.TimeSpan timeout,  Class System.Messaging.MessageQueueTransaction transaction);
     Class System.Messaging.Message ReceiveById( String id,  ValueClass System.TimeSpan timeout,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.Message ReceiveByCorrelationId( String correlationId);
     Class System.Messaging.Message ReceiveByCorrelationId( String correlationId,  Class System.Messaging.MessageQueueTransaction transaction);
     Class System.Messaging.Message ReceiveByCorrelationId( String correlationId,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.Message ReceiveByCorrelationId( String correlationId,  ValueClass System.TimeSpan timeout);
     Class System.Messaging.Message ReceiveByCorrelationId( String correlationId,  ValueClass System.TimeSpan timeout,  Class System.Messaging.MessageQueueTransaction transaction);
     Class System.Messaging.Message ReceiveByCorrelationId( String correlationId,  ValueClass System.TimeSpan timeout,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.Message ReceiveCurrent( ValueClass System.TimeSpan timeout,  I4 action,  I cursor,  Class System.Messaging.MessagePropertyFilter filter,  Class System.Messaging.MessageQueueTransaction internalTransaction,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Void Refresh();
     Void SaveQueueProperties();
     Void Send( Object obj);
     Void Send( Object obj,  Class System.Messaging.MessageQueueTransaction transaction);
     Void Send( Object obj,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Void Send( Object obj,  String label);
     Void Send( Object obj,  String label,  Class System.Messaging.MessageQueueTransaction transaction);
     Void Send( Object obj,  String label,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Void Send( Object obj,  String label,  Class System.Messaging.MessageQueueTransaction transaction,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Void SendInternal( Object obj,  Class System.Messaging.MessageQueueTransaction internalTransaction,  ValueClass System.Messaging.MessageQueueTransactionType transactionType);
     Class System.Messaging.MessageQueue ResolveQueueFromLabel( String path,  Boolean throwException);
     String ResolveFormatNameFromQueuePath( String queuePath,  Boolean throwException);
     Void ResetPermissions();
     Void SetPermissions( String user,  ValueClass System.Messaging.MessageQueueAccessRights rights);
     Void SetPermissions( String user,  ValueClass System.Messaging.MessageQueueAccessRights rights,  ValueClass System.Messaging.AccessControlEntryType entryType);
     Void SetPermissions( Class System.Messaging.MessageQueueAccessControlEntry ace);
     Void SetPermissions( Class System.Messaging.AccessControlList dacl);
     Boolean ValidatePath( String path,  Boolean checkQueueNameSize);
     I4 StaleSafePurgeQueue();
     I4 StaleSafeSendMessage( Class MQPROPS properties,  I transaction);
     I4 StaleSafeSendMessage( Class MQPROPS properties,  Class System.Messaging.Interop.ITransaction transaction);
     I4 StaleSafeReceiveMessage( UI4 timeout,  I4 action,  Class MQPROPS properties,  Ptr ValueClass System.Threading.NativeOverlapped overlapped,  Class ReceiveCallback receiveCallback,  I cursorHandle,  I transaction);
     I4 StaleSafeReceiveMessage( UI4 timeout,  I4 action,  Class MQPROPS properties,  Ptr ValueClass System.Threading.NativeOverlapped overlapped,  Class ReceiveCallback receiveCallback,  I cursorHandle,  Class System.Messaging.Interop.ITransaction transaction);
     Void System.Messaging.MessageQueue();

    property Authenticate { get(){} set(){} };
    property BasePriority { get(){} set(){} };
    property CanRead { get(){} set(){} };
    property CanWrite { get(){} set(){} };
    property Category { get(){} set(){} };
    property ComputerName { get(){} set(){} };
    property CreateTime { get(){} set(){} };
    property DefaultPropertiesToSend { get(){} set(){} };
    property DenySharedReceive { get(){} set(){} };
    property EnableConnectionCache { get(){} set(){} };
    property EncryptionRequired { get(){} set(){} };
    property FormatName { get(){} set(){} };
    property Formatter { get(){} set(){} };
    property Id { get(){} set(){} };
    property Label { get(){} set(){} };
    property LastModifyTime { get(){} set(){} };
    property MachineName { get(){} set(){} };
    property MaximumJournalSize { get(){} set(){} };
    property MaximumQueueSize { get(){} set(){} };
    property MessageReadPropertyFilter { get(){} set(){} };
    property MQInfo { get(){} set(){} };
    property Path { get(){} set(){} };
    property Properties { get(){} set(){} };
    property PropertyFilter { get(){} set(){} };
    property QueueName { get(){} set(){} };
    property QueuePath { get(){} set(){} };
    property ReadHandle { get(){} set(){} };
    property SynchronizingObject { get(){} set(){} };
    property Transactional { get(){} set(){} };
    property UseJournalQueue { get(){} set(){} };
    property WriteHandle { get(){} set(){} };

    event PeekCompleted;
    event ReceiveCompleted;
    }

class QueuePropertyFilter : System.Object
    {
     Boolean Authenticate;
     Boolean BasePriority;
     Boolean CreateTime;
     Boolean EncryptionLevel;
     Boolean Id;
     Boolean Transactional;
     Boolean Label;
     Boolean LastModifyTime;
     Boolean MaximumJournalSize;
     Boolean MaximumQueueSize;
     Boolean Path;
     Boolean Category;
     Boolean UseJournalQueue;

     Void ClearAll();
     Void QueuePropertyFilter();


    }

class AsynchronousRequest : System.Object
    {
     Class System.Threading.IOCompletionCallback onCompletionStatusChanged;
     Class ReceiveCallback onMessageReceived;
     Class System.AsyncCallback callback;
     Class System.Threading.ManualResetEvent resetEvent;
     Object asyncState;
     Class System.Messaging.MessageQueue owner;
     Boolean isCompleted;
     I4 status;
     Class System.Messaging.Message message;
     I4 action;
     UI4 timeout;

     Void AsynchronousRequest( Class System.Messaging.MessageQueue owner,  UI4 timeout,  I4 action,  Boolean useThreadPool,  Object asyncState,  Class System.AsyncCallback callback);
     I4 get_Action();
     Object get_AsyncObject();
     Object get_AsyncState();
     Class System.Threading.WaitHandle get_AsyncWaitHandle();
     Boolean get_CompletedSynchronously();
     Boolean get_IsCompleted();
     Void BeginRead();
     Class System.Messaging.Message End();
     Void OnCompletionStatusChanged( UI4 errorCode,  UI4 numBytes,  Ptr ValueClass System.Threading.NativeOverlapped overlappedPointer);
     Void OnMessageReceived( I4 result,  I handle,  I4 timeout,  I4 action,  I propertiesPointer,  Ptr ValueClass System.Threading.NativeOverlapped overlappedPointer,  I cursorHandle);
     Void RaiseCompletionEvent( I4 result,  Ptr ValueClass System.Threading.NativeOverlapped overlappedPointer);

    property Action { get(){} set(){} };
    property AsyncObject { get(){} set(){} };
    property AsyncState { get(){} set(){} };
    property AsyncWaitHandle { get(){} set(){} };
    property CompletedSynchronously { get(){} set(){} };
    property IsCompleted { get(){} set(){} };

    }

class CacheTable : System.Object
    {
     Class System.Collections.Hashtable table;
     Class System.Threading.ReaderWriterLock rwLock;
     String name;
     I4 capacity;
     I4 originalCapacity;
     ValueClass System.TimeSpan staleTime;

     Void CacheTable( String name,  I4 capacity,  ValueClass System.TimeSpan staleTime);
     Object Get( String key);
     Void Put( String key,  Object val);
     Void Remove( String key);
     Void ClearStale( ValueClass System.TimeSpan staleAge);


    }

class CacheEntry : System.Object
    {
     Object contents;
     ValueClass System.DateTime timeStamp;

     Void CacheEntry();


    }

class MQCacheableInfo : System.Object
    {
     I readHandle;
     I writeHandle;
     Boolean isTransactional;
     Boolean isTransactional_valid;
     Boolean boundToThreadPool;
     String formatName;
     I4 shareMode;
     I4 refCount;
     Boolean disposed;

     Void MQCacheableInfo( String formatName,  I4 shareMode);
     Void Finalize();
     Boolean get_CanRead();
     Boolean get_CanWrite();
     I4 get_RefCount();
     Void set_RefCount( I4 value);
     I get_ReadHandle();
     I get_WriteHandle();
     Boolean get_Transactional();
     Void AddRef();
     Void BindToThreadPool();
     Void CloseIfNotReferenced();
     Void Close();
     Void Dispose();
     Void Dispose( Boolean disposing);
     Void Release();

    property CanRead { get(){} set(){} };
    property CanWrite { get(){} set(){} };
    property RefCount { get(){} set(){} };
    property ReadHandle { get(){} set(){} };
    property WriteHandle { get(){} set(){} };
    property Transactional { get(){} set(){} };

    }

class System.Messaging.MessageQueueAccessControlEntry : System.Messaging.AccessControlEntry
    {

     Void System.Messaging.MessageQueueAccessControlEntry( Class System.Messaging.Trustee trustee,  ValueClass System.Messaging.MessageQueueAccessRights rights);
     Void System.Messaging.MessageQueueAccessControlEntry( Class System.Messaging.Trustee trustee,  ValueClass System.Messaging.MessageQueueAccessRights rights,  ValueClass System.Messaging.AccessControlEntryType entryType);
     ValueClass System.Messaging.MessageQueueAccessRights get_MessageQueueAccessRights();
     Void set_MessageQueueAccessRights( ValueClass System.Messaging.MessageQueueAccessRights value);

    property MessageQueueAccessRights { get(){} set(){} };

    }

class System.Messaging.MessageQueueAccessRights : System.Enum
    {
     I4 value__;
     ValueClass System.Messaging.MessageQueueAccessRights DeleteMessage;
     ValueClass System.Messaging.MessageQueueAccessRights PeekMessage;
     ValueClass System.Messaging.MessageQueueAccessRights WriteMessage;
     ValueClass System.Messaging.MessageQueueAccessRights DeleteJournalMessage;
     ValueClass System.Messaging.MessageQueueAccessRights SetQueueProperties;
     ValueClass System.Messaging.MessageQueueAccessRights GetQueueProperties;
     ValueClass System.Messaging.MessageQueueAccessRights DeleteQueue;
     ValueClass System.Messaging.MessageQueueAccessRights GetQueuePermissions;
     ValueClass System.Messaging.MessageQueueAccessRights ChangeQueuePermissions;
     ValueClass System.Messaging.MessageQueueAccessRights TakeQueueOwnership;
     ValueClass System.Messaging.MessageQueueAccessRights ReceiveMessage;
     ValueClass System.Messaging.MessageQueueAccessRights ReceiveJournalMessage;
     ValueClass System.Messaging.MessageQueueAccessRights GenericRead;
     ValueClass System.Messaging.MessageQueueAccessRights GenericWrite;
     ValueClass System.Messaging.MessageQueueAccessRights FullControl;



    }

class System.Messaging.MessageQueueCriteria : System.Object
    {
     ValueClass System.DateTime createdAfter;
     ValueClass System.DateTime createdBefore;
     String label;
     String machine;
     ValueClass System.DateTime modifiedAfter;
     ValueClass System.DateTime modifiedBefore;
     ValueClass System.Guid category;
     Class CriteriaProper