15Allow = NativeMethods.GRANT_ACCESS, 20Set = NativeMethods.SET_ACCESS, 25Deny = NativeMethods.DENY_ACCESS, 30Revoke = NativeMethods.REVOKE_ACCESS

124NativeMethods.ExplicitAccess[] entries = new NativeMethods.ExplicitAccess[ACECount]; 161entries[i].MultipleTrusteeOperation = NativeMethods.NO_MULTIPLE_TRUSTEE; 162entries[i].TrusteeForm = NativeMethods.TRUSTEE_IS_SID; 168if (err != NativeMethods.ERROR_SUCCESS)

41AccessDenied = NativeMethods.MESSAGE_CLASS_ACCESS_DENIED, 48BadDestinationQueue = NativeMethods.MESSAGE_CLASS_BAD_DESTINATION_QUEUE, 55BadEncryption = NativeMethods.MESSAGE_CLASS_BAD_ENCRYPTION, 62BadSignature = NativeMethods.MESSAGE_CLASS_BAD_SIGNATURE, 68CouldNotEncrypt = NativeMethods.MESSAGE_CLASS_COULD_NOT_ENCRYPT, 74HopCountExceeded = NativeMethods.MESSAGE_CLASS_HOP_COUNT_EXCEEDED, 81NotTransactionalQueue = NativeMethods.MESSAGE_CLASS_NOT_TRANSACTIONAL_QUEUE, 88NotTransactionalMessage = NativeMethods.MESSAGE_CLASS_NOT_TRANSACTIONAL_MESSAGE, 95Purged = NativeMethods.MESSAGE_CLASS_PURGED, 102QueueDeleted = NativeMethods.MESSAGE_CLASS_QUEUE_DELETED, 108QueueExceedMaximumSize = NativeMethods.MESSAGE_CLASS_QUEUE_EXCEED_QUOTA, 114QueuePurged = NativeMethods.MESSAGE_CLASS_QUEUE_PURGED, 120ReachQueue = NativeMethods.MESSAGE_CLASS_REACH_QUEUE, 127ReachQueueTimeout = NativeMethods.MESSAGE_CLASS_REACH_QUEUE_TIMEOUT, 134ReceiveTimeout = NativeMethods.MESSAGE_CLASS_RECEIVE_TIMEOUT, 141Receive = NativeMethods.MESSAGE_CLASS_RECEIVE,

32PositiveArrival = NativeMethods.ACKNOWLEDGE_POSITIVE_ARRIVAL, 41PositiveReceive = NativeMethods.ACKNOWLEDGE_POSITIVE_RECEIVE, 50NegativeReceive = NativeMethods.ACKNOWLEDGE_NEGATIVE_RECEIVE, 58None = NativeMethods.ACKNOWLEDGE_NONE, 68NotAcknowledgeReachQueue = NativeMethods.ACKNOWLEDGE_NEGATIVE_ARRIVAL, 79NativeMethods.ACKNOWLEDGE_NEGATIVE_ARRIVAL,

124bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 125size = message.properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE); 137bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 138size = message.properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE) / 2; 149bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 150size = message.properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE); 156bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 164bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 169bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 174bytes = message.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 229return NativeMethods.OleLoadFromStream(comStream, ref NativeMethods.IID_IUnknown); 259message.properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, this.internalBuffer); 260message.properties.AdjustSize(NativeMethods.MESSAGE_PROPID_BODY, size); 261message.properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE, size); 262message.properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_TYPE, VT_LPWSTR); 272message.properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, this.internalBuffer); 273message.properties.AdjustSize(NativeMethods.MESSAGE_PROPID_BODY, bytes.Length); 274message.properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE, bytes.Length); 275message.properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_TYPE, VT_UI1 | VT_VECTOR); 289message.properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, this.internalBuffer); 290message.properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE, size); 291message.properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_TYPE, VT_LPWSTR); 390NativeMethods.OleSaveToStream(pstream, comStream); 492ExternalException e = new ExternalException(msg, NativeMethods.E_FAIL); 498ExternalException e = new ExternalException(Res.GetString(Res.NotImplemented), NativeMethods.E_NOTIMPL); 531case NativeMethods.STREAM_SEEK_SET: 542case NativeMethods.STREAM_SEEK_END: 553case NativeMethods.STREAM_SEEK_CUR:

33RsaFull = NativeMethods.PROV_RSA_FULL, 39RsqSig = NativeMethods.PROV_RSA_SIG, 45Dss = NativeMethods.PROV_DSS, 51Fortezza = NativeMethods.PROV_FORTEZZA, 56MicrosoftExchange = NativeMethods.PROV_MS_EXCHANGE, 61Ssl = NativeMethods.PROV_SSL, 67SttMer = NativeMethods.PROV_STT_MER, 73SttAcq = NativeMethods.PROV_STT_ACQ, 79SttBrnd = NativeMethods.PROV_STT_BRND, 85SttRoot = NativeMethods.PROV_STT_ROOT, 91SttIss = NativeMethods.PROV_STT_ISS,

46Rc2 = NativeMethods.CALG_RC2, 59Rc4 = NativeMethods.CALG_RC4,

32None = NativeMethods.QUEUE_PRIVACY_LEVEL_NONE, 41Optional = NativeMethods.QUEUE_PRIVACY_LEVEL_OPTIONAL, 49Body = NativeMethods.QUEUE_PRIVACY_LEVEL_BODY

42Md2 = NativeMethods.CALG_MD2, 51Md4 = NativeMethods.CALG_MD4, 59Md5 = NativeMethods.CALG_MD5, 68Sha = NativeMethods.CALG_SHA, 76Mac = NativeMethods.CALG_MAC, 85Sha256 = NativeMethods.CALG_SHA256, 94Sha384 = NativeMethods.CALG_SHA384, 103Sha512 = NativeMethods.CALG_SHA512,

17: base(5, NativeMethods.MACHINE_BASE + 1)

82private int basePropertyId = NativeMethods.MESSAGE_PROPID_BASE + 1;

20: base(MaxQueuePropertyIndex, NativeMethods.QUEUE_PROPID_BASE + 1)

205public static extern int MQSetQueueSecurity(string formatName, int SecurityInformation, NativeMethods.SECURITY_DESCRIPTOR SecurityDescriptor); 211public static extern bool SetSecurityDescriptorDacl(NativeMethods.SECURITY_DESCRIPTOR pSD, bool daclPresent, IntPtr pDacl, bool daclDefaulted); 214public static extern bool InitializeSecurityDescriptor(NativeMethods.SECURITY_DESCRIPTOR SD, int revision);

75properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_MSGID, new byte[MessageIdSize]); 116properties.SetUI2(NativeMethods.MESSAGE_PROPID_CLASS, (short)0); 119properties.SetUI1(NativeMethods.MESSAGE_PROPID_ACKNOWLEDGE, (byte)0); 123properties.SetString(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE, new byte[DefaultQueueNameSize * 2]); 124properties.SetUI4(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN, DefaultQueueNameSize); 128properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, new byte[filter.bodySize]); 129properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE, filter.bodySize); 130properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_TYPE, 0); 134properties.SetString(NativeMethods.MESSAGE_PROPID_LABEL, new byte[filter.labelSize * 2]); 135properties.SetUI4(NativeMethods.MESSAGE_PROPID_LABEL_LEN, filter.labelSize); 138properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_MSGID, new byte[MessageIdSize]); 141properties.SetUI8(NativeMethods.MESSAGE_PROPID_LOOKUPID, (long)0); 144properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)0); 148properties.SetString(NativeMethods.MESSAGE_PROPID_RESP_QUEUE, new byte[DefaultQueueNameSize * 2]); 149properties.SetUI4(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN, DefaultQueueNameSize); 153properties.SetUI2(NativeMethods.MESSAGE_PROPID_CLASS, (short)0); 157properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)0); 164properties.SetUI4(NativeMethods.MESSAGE_PROPID_APPSPECIFIC, 0); 166properties.SetUI4(NativeMethods.MESSAGE_PROPID_ARRIVEDTIME, 0); 168properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_TYPE, 0); 170properties.SetUI1(NativeMethods.MESSAGE_PROPID_AUTHENTICATED, (byte)0); 173properties.SetGuid(NativeMethods.MESSAGE_PROPID_CONNECTOR_TYPE, new byte[GenericIdSize]); 175properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_CORRELATIONID, new byte[MessageIdSize]); 178properties.SetString(NativeMethods.MESSAGE_PROPID_PROV_NAME, new byte[DefaultCryptographicProviderNameSize * 2]); 179properties.SetUI4(NativeMethods.MESSAGE_PROPID_PROV_NAME_LEN, DefaultCryptographicProviderNameSize); 182properties.SetUI4(NativeMethods.MESSAGE_PROPID_PROV_TYPE, 0); 184properties.SetUI1(NativeMethods.MESSAGE_PROPID_DELIVERY, (byte)0); 187properties.SetString(NativeMethods.MESSAGE_PROPID_DEST_QUEUE, new byte[DefaultQueueNameSize * 2]); 188properties.SetUI4(NativeMethods.MESSAGE_PROPID_DEST_QUEUE_LEN, DefaultQueueNameSize); 192properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SIGNATURE, new byte[DefaultDigitalSignatureSize]); 193properties.SetUI4(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN, DefaultDigitalSignatureSize); 196properties.SetUI4(NativeMethods.MESSAGE_PROPID_ENCRYPTION_ALG, 0); 199properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_EXTENSION, new byte[filter.extensionSize]); 200properties.SetUI4(NativeMethods.MESSAGE_PROPID_EXTENSION_LEN, filter.extensionSize); 204properties.SetString(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE, new byte[DefaultQueueNameSize * 2]); 205properties.SetUI4(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN, DefaultQueueNameSize); 208properties.SetUI4(NativeMethods.MESSAGE_PROPID_HASH_ALG, 0); 210properties.SetUI1(NativeMethods.MESSAGE_PROPID_FIRST_IN_XACT, (byte)0); 212properties.SetUI1(NativeMethods.MESSAGE_PROPID_LAST_IN_XACT, (byte)0); 214properties.SetUI1(NativeMethods.MESSAGE_PROPID_PRIORITY, (byte)0); 217properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDER_CERT, new byte[DefaultSenderCertificateSize]); 218properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENDER_CERT_LEN, DefaultSenderCertificateSize); 222properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDERID, new byte[DefaultSenderIdSize]); 223properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_LEN, DefaultSenderIdSize); 226properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENTTIME, 0); 228properties.SetGuid(NativeMethods.MESSAGE_PROPID_SRC_MACHINE_ID, new byte[GenericIdSize]); 231properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY, new byte[DefaultSymmetricKeySize]); 232properties.SetUI4(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN, DefaultSymmetricKeySize); 235properties.SetUI4(NativeMethods.MESSAGE_PROPID_TIME_TO_BE_RECEIVED, 0); 237properties.SetUI4(NativeMethods.MESSAGE_PROPID_TIME_TO_REACH_QUEUE, 0); 239properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_XACTID, new byte[MessageIdSize]); 241properties.SetUI4(NativeMethods.MESSAGE_PROPID_AUTH_LEVEL, 0); 243properties.SetUI4(NativeMethods.MESSAGE_PROPID_PRIV_LEVEL, 0); 245properties.SetUI1(NativeMethods.MESSAGE_PROPID_TRACE, (byte)0); 247properties.SetUI4(NativeMethods.MESSAGE_PROPID_VERSION, 0); 271int res = ((int)properties.GetUI2(NativeMethods.MESSAGE_PROPID_CLASS)) & 0x0000FFFF; 299return (AcknowledgeTypes)this.properties.GetUI1(NativeMethods.MESSAGE_PROPID_ACKNOWLEDGE); 308properties.Remove(NativeMethods.MESSAGE_PROPID_ACKNOWLEDGE); 313this.properties.SetUI1(NativeMethods.MESSAGE_PROPID_ACKNOWLEDGE, (byte)value); 341if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN) != 0) 343string queueFormatName = StringFromBytes(properties.GetString(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE), 344properties.GetUI4(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN)); 363properties.Remove(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE); 364properties.Remove(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN); 393return properties.GetUI4(NativeMethods.MESSAGE_PROPID_APPSPECIFIC); 402properties.Remove(NativeMethods.MESSAGE_PROPID_APPSPECIFIC); 407properties.SetUI4(NativeMethods.MESSAGE_PROPID_APPSPECIFIC, value); 432time = time.AddSeconds(properties.GetUI4(NativeMethods.MESSAGE_PROPID_ARRIVEDTIME)).ToLocalTime(); 458int type = properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_TYPE); 459if (type == NativeMethods.MESSAGE_SENDERID_TYPE_NONE) 471properties.Remove(NativeMethods.MESSAGE_PROPID_SENDERID_TYPE); 477properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_TYPE, NativeMethods.MESSAGE_SENDERID_TYPE_SID); 479properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_TYPE, NativeMethods.MESSAGE_SENDERID_TYPE_NONE); 505return (properties.GetUI1(NativeMethods.MESSAGE_PROPID_AUTHENTICATED) != 0); 530if (this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_PROV_NAME_LEN) != 0) 531return StringFromBytes(this.properties.GetString(NativeMethods.MESSAGE_PROPID_PROV_NAME), 532properties.GetUI4(NativeMethods.MESSAGE_PROPID_PROV_NAME_LEN)); 550properties.SetString(NativeMethods.MESSAGE_PROPID_PROV_NAME, StringToBytes(value)); 551properties.SetUI4(NativeMethods.MESSAGE_PROPID_PROV_NAME_LEN, value.Length); 578return (CryptographicProviderType)properties.GetUI4(NativeMethods.MESSAGE_PROPID_PROV_TYPE); 593properties.SetUI4(NativeMethods.MESSAGE_PROPID_PROV_TYPE, (int)value); 667this.cachedBodyStream = new MemoryStream(properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY), 6680, properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE)); 680properties.Remove(NativeMethods.MESSAGE_PROPID_BODY); 681properties.Remove(NativeMethods.MESSAGE_PROPID_BODY_TYPE); 682properties.Remove(NativeMethods.MESSAGE_PROPID_BODY_SIZE); 710return this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_TYPE); 715properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_TYPE, value); 745return new Guid(this.properties.GetGuid(NativeMethods.MESSAGE_PROPID_CONNECTOR_TYPE)); 754properties.Remove(NativeMethods.MESSAGE_PROPID_CONNECTOR_TYPE); 759properties.SetGuid(NativeMethods.MESSAGE_PROPID_CONNECTOR_TYPE, ((Guid)value).ToByteArray()); 786return IdFromByteArray(this.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_CORRELATIONID)); 798properties.Remove(NativeMethods.MESSAGE_PROPID_CORRELATIONID); 803properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_CORRELATIONID, IdToByteArray(value)); 874if (this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_QUEUE_LEN) != 0) 876string queueFormatName = StringFromBytes(properties.GetString(NativeMethods.MESSAGE_PROPID_DEST_QUEUE), 877properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_QUEUE_LEN)); 909byte[] bytes = new byte[properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN)]; 910Array.Copy(properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY), bytes, bytes.Length); 923properties.Remove(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY); 924properties.Remove(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN); 929properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY, value); 930properties.SetUI4(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN, value.Length); 958byte[] bytes = new byte[properties.GetUI4(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN)]; 959Array.Copy(properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_SIGNATURE), bytes, bytes.Length); 971properties.Remove(NativeMethods.MESSAGE_PROPID_SIGNATURE); 972properties.Remove(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN); 979properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SIGNATURE, value); 980properties.SetUI4(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN, value.Length); 1006return (EncryptionAlgorithm)properties.GetUI4(NativeMethods.MESSAGE_PROPID_ENCRYPTION_ALG); 1020properties.SetUI4(NativeMethods.MESSAGE_PROPID_ENCRYPTION_ALG, (int)value); 1049byte[] bytes = new byte[properties.GetUI4(NativeMethods.MESSAGE_PROPID_EXTENSION_LEN)]; 1050Array.Copy(properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_EXTENSION), bytes, bytes.Length); 1063properties.Remove(NativeMethods.MESSAGE_PROPID_EXTENSION); 1064properties.Remove(NativeMethods.MESSAGE_PROPID_EXTENSION_LEN); 1069properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_EXTENSION, value); 1070properties.SetUI4(NativeMethods.MESSAGE_PROPID_EXTENSION_LEN, value.Length); 1126return (HashAlgorithm)properties.GetUI4(NativeMethods.MESSAGE_PROPID_HASH_ALG); 1141properties.SetUI4(NativeMethods.MESSAGE_PROPID_HASH_ALG, (int)value); 1167return IdFromByteArray(this.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_MSGID)); 1191return (properties.GetUI1(NativeMethods.MESSAGE_PROPID_FIRST_IN_XACT) != 0); 1215return (properties.GetUI1(NativeMethods.MESSAGE_PROPID_LAST_IN_XACT) != 0); 1239if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_LABEL_LEN) != 0) 1240return StringFromBytes(this.properties.GetString(NativeMethods.MESSAGE_PROPID_LABEL), 1241properties.GetUI4(NativeMethods.MESSAGE_PROPID_LABEL_LEN)); 1255properties.Remove(NativeMethods.MESSAGE_PROPID_LABEL); 1256properties.Remove(NativeMethods.MESSAGE_PROPID_LABEL_LEN); 1261properties.SetString(NativeMethods.MESSAGE_PROPID_LABEL, StringToBytes(value)); 1262properties.SetUI4(NativeMethods.MESSAGE_PROPID_LABEL_LEN, value.Length); 1289return this.properties.GetUI8(NativeMethods.MESSAGE_PROPID_LOOKUPID); 1296this.properties.SetUI8(NativeMethods.MESSAGE_PROPID_LOOKUPID, value); 1319int cls = properties.GetUI2(NativeMethods.MESSAGE_PROPID_CLASS); 1320if (cls == NativeMethods.MESSAGE_CLASS_NORMAL) 1323if (cls == NativeMethods.MESSAGE_CLASS_REPORT) 1353return (MessagePriority)properties.GetUI1(NativeMethods.MESSAGE_PROPID_PRIORITY); 1365properties.Remove(NativeMethods.MESSAGE_PROPID_PRIORITY); 1370properties.SetUI1(NativeMethods.MESSAGE_PROPID_PRIORITY, (byte)value); 1397return properties.GetUI1(NativeMethods.MESSAGE_PROPID_DELIVERY) == NativeMethods.MESSAGE_DELIVERY_RECOVERABLE; 1406properties.Remove(NativeMethods.MESSAGE_PROPID_DELIVERY); 1411properties.SetUI1(NativeMethods.MESSAGE_PROPID_DELIVERY, (byte)NativeMethods.MESSAGE_DELIVERY_RECOVERABLE); 1439if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN) != 0) 1441string queueFormatName = StringFromBytes(properties.GetString(NativeMethods.MESSAGE_PROPID_RESP_QUEUE), 1442properties.GetUI4(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN)); 1461properties.Remove(NativeMethods.MESSAGE_PROPID_RESP_QUEUE); 1462properties.Remove(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN); 1479IntPtr handle = (IntPtr)(int)properties.GetUI4(NativeMethods.MESSAGE_PROPID_SECURITY_CONTEXT); 1488properties.Remove(NativeMethods.MESSAGE_PROPID_SECURITY_CONTEXT); 1495properties.SetUI4(NativeMethods.MESSAGE_PROPID_SECURITY_CONTEXT, handle); 1524byte[] bytes = new byte[properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENDER_CERT_LEN)]; 1525Array.Copy(properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDER_CERT), bytes, bytes.Length); 1538properties.Remove(NativeMethods.MESSAGE_PROPID_SENDER_CERT); 1539properties.Remove(NativeMethods.MESSAGE_PROPID_SENDER_CERT_LEN); 1544properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDER_CERT, value); 1545properties.SetUI4(NativeMethods.MESSAGE_PROPID_SENDER_CERT_LEN, value.Length); 1573byte[] bytes = new byte[properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_LEN)]; 1574Array.Copy(properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDERID), bytes, bytes.Length); 1598return (long)((uint)properties.GetUI4(NativeMethods.MESSAGE_PROPID_VERSION)); 1622time = time.AddSeconds(properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENTTIME)).ToLocalTime(); 1646byte[] bytes = this.properties.GetGuid(NativeMethods.MESSAGE_PROPID_SRC_MACHINE_ID); 1650machineProperties.SetNull(NativeMethods.MACHINE_PATHNAME); 1655IntPtr memoryHandle = machineProperties.GetIntPtr(NativeMethods.MACHINE_PATHNAME); 1696return TimeSpan.FromSeconds((uint)properties.GetUI4(NativeMethods.MESSAGE_PROPID_TIME_TO_BE_RECEIVED)); 1712properties.Remove(NativeMethods.MESSAGE_PROPID_TIME_TO_BE_RECEIVED); 1717properties.SetUI4(NativeMethods.MESSAGE_PROPID_TIME_TO_BE_RECEIVED, (int)((uint)timeoutInSeconds)); 1746return TimeSpan.FromSeconds((uint)properties.GetUI4(NativeMethods.MESSAGE_PROPID_TIME_TO_REACH_QUEUE)); 1761properties.Remove(NativeMethods.MESSAGE_PROPID_TIME_TO_REACH_QUEUE); 1766properties.SetUI4(NativeMethods.MESSAGE_PROPID_TIME_TO_REACH_QUEUE, (int)((uint)timeoutInSeconds)); 1792return IdFromByteArray(this.properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_XACTID)); 1819if (this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN) != 0) 1821string queueFormatName = StringFromBytes(properties.GetString(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE), 1822properties.GetUI4(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN)); 1841properties.Remove(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE); 1842properties.Remove(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN); 1882return (properties.GetUI4(NativeMethods.MESSAGE_PROPID_AUTH_LEVEL) != NativeMethods.MESSAGE_AUTHENTICATION_LEVEL_NONE); 1892properties.SetUI4(NativeMethods.MESSAGE_PROPID_AUTH_LEVEL, NativeMethods.MESSAGE_AUTHENTICATION_LEVEL_NONE); 1896properties.SetUI4(NativeMethods.MESSAGE_PROPID_AUTH_LEVEL, NativeMethods.MESSAGE_AUTHENTICATION_LEVEL_ALWAYS); 1922return ((properties.GetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL) & NativeMethods.MESSAGE_JOURNAL_DEADLETTER) != 0); 1934properties.Remove(NativeMethods.MESSAGE_PROPID_JOURNAL); 1936properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)(properties.GetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL) & ~NativeMethods.MESSAGE_JOURNAL_DEADLETTER)); 1942properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)NativeMethods.MESSAGE_JOURNAL_DEADLETTER); 1944properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)(properties.GetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL) | NativeMethods.MESSAGE_JOURNAL_DEADLETTER)); 1971return (properties.GetUI4(NativeMethods.MESSAGE_PROPID_PRIV_LEVEL) != NativeMethods.MESSAGE_PRIVACY_LEVEL_NONE); 1980properties.Remove(NativeMethods.MESSAGE_PROPID_PRIV_LEVEL); 1985properties.SetUI4(NativeMethods.MESSAGE_PROPID_PRIV_LEVEL, NativeMethods.MESSAGE_PRIVACY_LEVEL_BODY); 2011return ((properties.GetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL) & NativeMethods.MESSAGE_JOURNAL_JOURNAL) != 0); 2023properties.Remove(NativeMethods.MESSAGE_PROPID_JOURNAL); 2025properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)(properties.GetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL) & ~NativeMethods.MESSAGE_JOURNAL_JOURNAL)); 2031properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)NativeMethods.MESSAGE_JOURNAL_JOURNAL); 2033properties.SetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL, (byte)(properties.GetUI1(NativeMethods.MESSAGE_PROPID_JOURNAL) | NativeMethods.MESSAGE_JOURNAL_JOURNAL)); 2062return (properties.GetUI1(NativeMethods.MESSAGE_PROPID_TRACE) != NativeMethods.MESSAGE_TRACE_NONE); 2071properties.Remove(NativeMethods.MESSAGE_PROPID_TRACE); 2078properties.SetUI1(NativeMethods.MESSAGE_PROPID_TRACE, (byte)NativeMethods.MESSAGE_TRACE_NONE); 2080properties.SetUI1(NativeMethods.MESSAGE_PROPID_TRACE, (byte)NativeMethods.MESSAGE_TRACE_SEND_ROUTE_TO_REPORT_QUEUE); 2091int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN); 2093properties.SetString(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE, new byte[size * 2]); 2098int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE); 2100properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, new byte[size]); 2105int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_PROV_NAME_LEN); 2107properties.SetString(NativeMethods.MESSAGE_PROPID_PROV_NAME, new byte[size * 2]); 2112int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_QUEUE_LEN); 2114properties.SetString(NativeMethods.MESSAGE_PROPID_DEST_QUEUE, new byte[size * 2]); 2119int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_EXTENSION_LEN); 2121properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_EXTENSION, new byte[size]); 2126int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN); 2128properties.SetString(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE, new byte[size * 2]); 2133int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_LABEL_LEN); 2135properties.SetString(NativeMethods.MESSAGE_PROPID_LABEL, new byte[size * 2]); 2140int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN); 2142properties.SetString(NativeMethods.MESSAGE_PROPID_RESP_QUEUE, new byte[size * 2]); 2147int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENDER_CERT_LEN); 2149properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDER_CERT, new byte[size]); 2154int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENDERID_LEN); 2156properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SENDERID, new byte[size]); 2161int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN); 2163properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY, new byte[size]); 2168int size = properties.GetUI4(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN); 2170properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_SIGNATURE, new byte[size]); 2183properties.SetString(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE, StringToBytes(queueFormatName)); 2184properties.SetUI4(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN, queueFormatName.Length); 2190properties.SetString(NativeMethods.MESSAGE_PROPID_RESP_QUEUE, StringToBytes(queueFormatName)); 2191properties.SetUI4(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN, queueFormatName.Length); 2197properties.SetString(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE, StringToBytes(queueFormatName)); 2198properties.SetUI4(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN, queueFormatName.Length); 2214properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, bytes); 2215properties.SetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE, bytes.Length); 2229int bodySize = properties.GetUI4(NativeMethods.MESSAGE_PROPID_BODY_SIZE); 2230byte[] bodyArray = properties.GetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY); 2240properties.SetUI1Vector(NativeMethods.MESSAGE_PROPID_BODY, bytes); 2245this.properties.AdjustSize(NativeMethods.MESSAGE_PROPID_EXTENSION, 2246this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_EXTENSION_LEN)); 2250this.properties.AdjustSize(NativeMethods.MESSAGE_PROPID_SENDER_CERT, 2251this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_SENDER_CERT_LEN)); 2255this.properties.AdjustSize(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY, 2256this.properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN)); 2261this.properties.Ghost(NativeMethods.MESSAGE_PROPID_CLASS); 2263this.properties.Ghost(NativeMethods.MESSAGE_PROPID_ARRIVEDTIME); 2265this.properties.Ghost(NativeMethods.MESSAGE_PROPID_AUTHENTICATED); 2268this.properties.Ghost(NativeMethods.MESSAGE_PROPID_DEST_QUEUE); 2269this.properties.Ghost(NativeMethods.MESSAGE_PROPID_DEST_QUEUE_LEN); 2273this.properties.Ghost(NativeMethods.MESSAGE_PROPID_FIRST_IN_XACT); 2275this.properties.Ghost(NativeMethods.MESSAGE_PROPID_LAST_IN_XACT); 2278this.properties.Ghost(NativeMethods.MESSAGE_PROPID_SENDERID); 2279this.properties.Ghost(NativeMethods.MESSAGE_PROPID_SENDERID_LEN); 2282this.properties.Ghost(NativeMethods.MESSAGE_PROPID_SENTTIME); 2284this.properties.Ghost(NativeMethods.MESSAGE_PROPID_SRC_MACHINE_ID); 2286this.properties.Ghost(NativeMethods.MESSAGE_PROPID_XACTID); 2288this.properties.Ghost(NativeMethods.MESSAGE_PROPID_VERSION); 2294if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN) == 0) 2296this.properties.Ghost(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE); 2297this.properties.Ghost(NativeMethods.MESSAGE_PROPID_ADMIN_QUEUE_LEN); 2304this.properties.Ghost(NativeMethods.MESSAGE_PROPID_ENCRYPTION_ALG); 2308if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN) == 0) 2310this.properties.Ghost(NativeMethods.MESSAGE_PROPID_SIGNATURE); 2311this.properties.Ghost(NativeMethods.MESSAGE_PROPID_SIGNATURE_LEN); 2316if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN) == 0) 2318this.properties.Ghost(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY); 2319this.properties.Ghost(NativeMethods.MESSAGE_PROPID_DEST_SYMM_KEY_LEN); 2324if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN) == 0) 2326this.properties.Ghost(NativeMethods.MESSAGE_PROPID_RESP_QUEUE); 2327this.properties.Ghost(NativeMethods.MESSAGE_PROPID_RESP_QUEUE_LEN); 2332if (properties.GetUI4(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN) == 0) 2334this.properties.Ghost(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE); 2335this.properties.Ghost(NativeMethods.MESSAGE_PROPID_XACT_STATUS_QUEUE_LEN);

51return this.owner.ReceiveCurrent(TimeSpan.Zero, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, this.Handle, 163int action = NativeMethods.QUEUE_ACTION_PEEK_NEXT; 166action = NativeMethods.QUEUE_ACTION_PEEK_CURRENT; 168status = owner.StaleSafeReceiveMessage((uint)timeoutInMilliseconds, action, null, null, null, this.Handle, (IntPtr)NativeMethods.QUEUE_TRANSACTION_NONE); 271Message message = this.owner.ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE,

228this.sharedMode = NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE; 249this.sharedMode = NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE; 299Properties.SetUI1(NativeMethods.QUEUE_PROPID_AUTHENTICATE, (byte)0); 301this.authenticate = (Properties.GetUI1(NativeMethods.QUEUE_PROPID_AUTHENTICATE) != NativeMethods.QUEUE_AUTHENTICATE_NONE); 303Properties.Remove(NativeMethods.QUEUE_PROPID_AUTHENTICATE); 312Properties.SetUI1(NativeMethods.QUEUE_PROPID_AUTHENTICATE, (byte)NativeMethods.QUEUE_AUTHENTICATE_AUTHENTICATE); 314Properties.SetUI1(NativeMethods.QUEUE_PROPID_AUTHENTICATE, (byte)NativeMethods.QUEUE_AUTHENTICATE_NONE); 319Properties.Remove(NativeMethods.QUEUE_PROPID_AUTHENTICATE); 335Properties.SetI2(NativeMethods.QUEUE_PROPID_BASEPRIORITY, (short)0); 337this.basePriority = properties.GetI2(NativeMethods.QUEUE_PROPID_BASEPRIORITY); 339Properties.Remove(NativeMethods.QUEUE_PROPID_BASEPRIORITY); 348Properties.SetI2(NativeMethods.QUEUE_PROPID_BASEPRIORITY, value); 352Properties.Remove(NativeMethods.QUEUE_PROPID_BASEPRIORITY); 415Properties.SetNull(NativeMethods.QUEUE_PROPID_TYPE); 418IntPtr handle = Properties.GetIntPtr(NativeMethods.QUEUE_PROPID_TYPE); 428Properties.Remove(NativeMethods.QUEUE_PROPID_TYPE); 435Properties.SetGuid(NativeMethods.QUEUE_PROPID_TYPE, value.ToByteArray()); 439Properties.Remove(NativeMethods.QUEUE_PROPID_TYPE); 480Properties.SetI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, 0); 482this.createTime = time.AddSeconds(properties.GetI4(NativeMethods.QUEUE_PROPID_CREATE_TIME)).ToLocalTime(); 484Properties.Remove(NativeMethods.QUEUE_PROPID_CREATE_TIME); 534return (this.sharedMode == NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE); 538if (value && (this.sharedMode != NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE)) 541this.sharedMode = NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE; 543else if (!value && (this.sharedMode == NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE)) 546this.sharedMode = NativeMethods.QUEUE_SHARED_MODE_DENY_NONE; 583Properties.SetUI4(NativeMethods.QUEUE_PROPID_PRIV_LEVEL, 0); 585this.encryptionLevel = Properties.GetUI4(NativeMethods.QUEUE_PROPID_PRIV_LEVEL); 587Properties.Remove(NativeMethods.QUEUE_PROPID_PRIV_LEVEL); 597Properties.SetUI4(NativeMethods.QUEUE_PROPID_PRIV_LEVEL, (int)value); 599this.encryptionLevel = properties.GetUI4(NativeMethods.QUEUE_PROPID_PRIV_LEVEL); 601Properties.Remove(NativeMethods.QUEUE_PROPID_PRIV_LEVEL); 639StringBuilder newFormatName = new StringBuilder(NativeMethods.MAX_LABEL_LEN); 640result = NativeMethods.MAX_LABEL_LEN; 715Properties.SetNull(NativeMethods.QUEUE_PROPID_INSTANCE); 718IntPtr handle = Properties.GetIntPtr(NativeMethods.QUEUE_PROPID_INSTANCE); 727Properties.Remove(NativeMethods.QUEUE_PROPID_INSTANCE); 744Properties.SetNull(NativeMethods.QUEUE_PROPID_LABEL); 747IntPtr handle = Properties.GetIntPtr(NativeMethods.QUEUE_PROPID_LABEL); 758Properties.Remove(NativeMethods.QUEUE_PROPID_LABEL); 770Properties.SetString(NativeMethods.QUEUE_PROPID_LABEL, Message.StringToBytes(value)); 774Properties.Remove(NativeMethods.QUEUE_PROPID_LABEL); 793Properties.SetI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, 0); 795this.lastModifyTime = time.AddSeconds(properties.GetI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME)).ToLocalTime(); 797Properties.Remove(NativeMethods.QUEUE_PROPID_MODIFY_TIME); 865Properties.SetUI4(NativeMethods.QUEUE_PROPID_JOURNAL_QUOTA, 0); 867this.journalSize = (long)((uint)properties.GetUI4(NativeMethods.QUEUE_PROPID_JOURNAL_QUOTA)); 869Properties.Remove(NativeMethods.QUEUE_PROPID_JOURNAL_QUOTA); 880Properties.SetUI4(NativeMethods.QUEUE_PROPID_JOURNAL_QUOTA, (int)((uint)value)); 884Properties.Remove(NativeMethods.QUEUE_PROPID_JOURNAL_QUOTA); 903Properties.SetUI4(NativeMethods.QUEUE_PROPID_QUOTA, 0); 905this.queueSize = (long)((uint)properties.GetUI4(NativeMethods.QUEUE_PROPID_QUOTA)); 907Properties.Remove(NativeMethods.QUEUE_PROPID_QUOTA); 918Properties.SetUI4(NativeMethods.QUEUE_PROPID_QUOTA, (int)((uint)value)); 922Properties.Remove(NativeMethods.QUEUE_PROPID_QUOTA); 963if (sharedMode == NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE || !enableCache) 1016Properties.SetNull(NativeMethods.QUEUE_PROPID_MULTICAST_ADDRESS); 1019IntPtr handle = Properties.GetIntPtr(NativeMethods.QUEUE_PROPID_MULTICAST_ADDRESS); 1029Properties.Remove(NativeMethods.QUEUE_PROPID_MULTICAST_ADDRESS); 1043Properties.SetEmpty(NativeMethods.QUEUE_PROPID_MULTICAST_ADDRESS); 1045Properties.SetString(NativeMethods.QUEUE_PROPID_MULTICAST_ADDRESS, Message.StringToBytes(value)); 1050Properties.Remove(NativeMethods.QUEUE_PROPID_MULTICAST_ADDRESS); 1181Properties.SetNull(NativeMethods.QUEUE_PROPID_PATHNAME); 1184IntPtr handle = Properties.GetIntPtr(NativeMethods.QUEUE_PROPID_PATHNAME); 1192Properties.Remove(NativeMethods.QUEUE_PROPID_PATHNAME); 1298Properties.SetUI1(NativeMethods.QUEUE_PROPID_JOURNAL, (byte)0); 1300this.useJournaling = (Properties.GetUI1(NativeMethods.QUEUE_PROPID_JOURNAL) != NativeMethods.QUEUE_JOURNAL_NONE); 1302Properties.Remove(NativeMethods.QUEUE_PROPID_JOURNAL); 1310Properties.SetUI1(NativeMethods.QUEUE_PROPID_JOURNAL, (byte)NativeMethods.QUEUE_JOURNAL_JOURNAL); 1312Properties.SetUI1(NativeMethods.QUEUE_PROPID_JOURNAL, (byte)NativeMethods.QUEUE_JOURNAL_NONE); 1317Properties.Remove(NativeMethods.QUEUE_PROPID_JOURNAL); 1457return ReceiveAsync(InfiniteTimeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, null, null); 1470return ReceiveAsync(timeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, null, null); 1485return ReceiveAsync(timeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, null, stateObject); 1499return ReceiveAsync(timeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, callback, stateObject); 1524return ReceiveAsync(InfiniteTimeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_RECEIVE, null, null); 1538return ReceiveAsync(timeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_RECEIVE, null, null); 1552return ReceiveAsync(timeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_RECEIVE, null, stateObject); 1565return ReceiveAsync(timeout, CursorHandle.NullHandle, NativeMethods.QUEUE_ACTION_RECEIVE, callback, stateObject); 1574return ReceiveAsync(timeout, cursor.Handle, NativeMethods.QUEUE_ACTION_RECEIVE, callback, state); 1622if (sharedMode == NativeMethods.QUEUE_SHARED_MODE_DENY_RECEIVE || !enableCache) 1669properties.SetString(NativeMethods.QUEUE_PROPID_PATHNAME, Message.StringToBytes(path)); 1671properties.SetUI1(NativeMethods.QUEUE_PROPID_TRANSACTION, (byte)NativeMethods.QUEUE_TRANSACTIONAL_TRANSACTIONAL); 1673properties.SetUI1(NativeMethods.QUEUE_PROPID_TRANSACTION, (byte)NativeMethods.QUEUE_TRANSACTIONAL_NONE); 1675StringBuilder formatName = new StringBuilder(NativeMethods.MAX_LABEL_LEN); 1676int formatNameLen = NativeMethods.MAX_LABEL_LEN; 1909machineProperties.SetNull(NativeMethods.MACHINE_ID); 1912IntPtr handle = machineProperties.GetIntPtr(NativeMethods.MACHINE_ID); 1939int status = NativeMethods.MQGetSecurityContextEx(out handle); 2035properties.SetNull(NativeMethods.MANAGEMENT_PRIVATEQ); 2041uint len = properties.GetStringVectorLength(NativeMethods.MANAGEMENT_PRIVATEQ); 2042IntPtr basePointer = properties.GetStringVectorBasePointer(NativeMethods.MANAGEMENT_PRIVATEQ); 2244if (((AsynchronousRequest)asyncResult).Action == NativeMethods.QUEUE_ACTION_PEEK_CURRENT) 2275return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, CursorHandle.NullHandle, MessageReadPropertyFilter, null, MessageQueueTransactionType.None); 2290return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, CursorHandle.NullHandle, MessageReadPropertyFilter, null, MessageQueueTransactionType.None); 2398return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, null, MessageQueueTransactionType.None); 2414return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, transaction, MessageQueueTransactionType.None); 2426return ReceiveCurrent(InfiniteTimeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, null, transactionType); 2440return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, null, MessageQueueTransactionType.None); 2449return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursor.Handle, MessageReadPropertyFilter, null, MessageQueueTransactionType.None); 2466return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, transaction, MessageQueueTransactionType.None); 2479return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, CursorHandle.NullHandle, MessageReadPropertyFilter, null, transactionType); 2491return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursor.Handle, MessageReadPropertyFilter, transaction, MessageQueueTransactionType.None); 2504return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursor.Handle, MessageReadPropertyFilter, null, transactionType); 2515if (action == NativeMethods.QUEUE_ACTION_RECEIVE) 2631Message message = this.ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, cursorHandle, 2647return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursorHandle, 2650return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_RECEIVE, cursorHandle, 2654return ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_PEEK_CURRENT, cursorHandle, 2661message = this.ReceiveCurrent(timeout, NativeMethods.QUEUE_ACTION_PEEK_NEXT, cursorHandle, 2938action = NativeMethods.LOOKUP_RECEIVE_MASK | (int)lookupAction; 2951action = NativeMethods.LOOKUP_PEEK_MASK | (int)lookupAction; 3022if (action == NativeMethods.QUEUE_ACTION_RECEIVE) 3071if (action == NativeMethods.QUEUE_ACTION_PEEK_NEXT) 3072action = NativeMethods.QUEUE_ACTION_PEEK_CURRENT; 3358StringBuilder newFormatName = new StringBuilder(NativeMethods.MAX_LABEL_LEN); 3359result = NativeMethods.MAX_LABEL_LEN; 3392int result = UnsafeNativeMethods.MQSetQueueSecurity(FormatName, NativeMethods.DACL_SECURITY_INFORMATION, null); 3393if (result != NativeMethods.MQ_OK) 3469NativeMethods.DACL_SECURITY_INFORMATION, 3474if (mqResult == NativeMethods.MQ_ERROR_SECURITY_DESCRIPTOR_TOO_SMALL) 3480NativeMethods.DACL_SECURITY_INFORMATION, 3486if (mqResult != NativeMethods.MQ_OK) 3504NativeMethods.SECURITY_DESCRIPTOR newSecurityDescriptor = new NativeMethods.SECURITY_DESCRIPTOR(); 3506NativeMethods.SECURITY_DESCRIPTOR_REVISION); 3519NativeMethods.DACL_SECURITY_INFORMATION, 3522if (result != NativeMethods.MQ_OK) 3797if (this.action == NativeMethods.QUEUE_ACTION_PEEK_NEXT) 3798this.action = NativeMethods.QUEUE_ACTION_PEEK_CURRENT; 3904if (this.action == NativeMethods.QUEUE_ACTION_PEEK_NEXT) 3905this.action = NativeMethods.QUEUE_ACTION_PEEK_CURRENT; 4442props.SetUI1(NativeMethods.QUEUE_PROPID_TRANSACTION, (byte)0); 4448this.isTransactional = (props.GetUI1(NativeMethods.QUEUE_PROPID_TRANSACTION) != NativeMethods.QUEUE_TRANSACTIONAL_NONE);

254restrictions.AddI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, Restrictions.PRGT, ConvertTime(this.createdAfter)); 256restrictions.AddI4(NativeMethods.QUEUE_PROPID_CREATE_TIME, Restrictions.PRLE, ConvertTime(this.createdBefore)); 258restrictions.AddString(NativeMethods.QUEUE_PROPID_LABEL, Restrictions.PREQ, this.label); 260restrictions.AddI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, Restrictions.PRGT, ConvertTime(this.modifiedAfter)); 262restrictions.AddI4(NativeMethods.QUEUE_PROPID_MODIFY_TIME, Restrictions.PRLE, ConvertTime(this.modifiedBefore)); 264restrictions.AddGuid(NativeMethods.QUEUE_PROPID_TYPE, Restrictions.PREQ, this.category);

149columns.AddColumnId(NativeMethods.QUEUE_PROPID_PATHNAME); 152columns.AddColumnId(NativeMethods.QUEUE_PROPID_INSTANCE);

22None = NativeMethods.QUEUE_TRANSACTION_NONE, 27Automatic = NativeMethods.QUEUE_TRANSACTION_MTS, 32Single = NativeMethods.QUEUE_TRANSACTION_SINGLE,

16Current = NativeMethods.QUEUE_ACTION_PEEK_CURRENT, 18Next = NativeMethods.QUEUE_ACTION_PEEK_NEXT

25Send = NativeMethods.QUEUE_ACCESS_SEND, 26Peek = NativeMethods.QUEUE_ACCESS_PEEK, 27Receive = NativeMethods.QUEUE_ACCESS_RECEIVE, 28PeekAndAdmin = NativeMethods.QUEUE_ACCESS_PEEK | NativeMethods.QUEUE_ACCESS_ADMIN, 29ReceiveAndAdmin = NativeMethods.QUEUE_ACCESS_RECEIVE | NativeMethods.QUEUE_ACCESS_ADMIN, 34SendAndReceive = NativeMethods.QUEUE_ACCESS_SEND | NativeMethods.QUEUE_ACCESS_RECEIVE,