1: using System;
2: using System.Collections.Generic;
3:
4: namespace Ia.Ngn.Cl.Model.Data
5: {
6: ////////////////////////////////////////////////////////////////////////////
7:
8: /// <summary publish="true">
9: /// MSMQ support class for Optical Fiber Network (OFN) data model.
10: /// </summary>
11: ///
12: /// <remarks>
13: /// Copyright © 2018-2022 Jasem Y. Al-Shamlan (info@ia.com.kw), Integrated Applications - Kuwait. All Rights Reserved.
14: ///
15: /// This library is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by
16: /// the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
17: ///
18: /// This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
19: /// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
20: ///
21: /// You should have received a copy of the GNU General Public License along with this library. If not, see http://www.gnu.org/licenses.
22: ///
23: /// Copyright notice: This notice may not be removed or altered from any source distribution.
24: /// </remarks>
25: public abstract class Msmq
26: {
27: // If you have issues with Denied Access,...etc see C:\Users\Jasem\Documents\Business\Internet Programming\Research\MSMQ (Microsoft Message Queuing)
28:
29: ////////////////////////////////////////////////////////////////////////////
30: ////////////////////////////////////////////////////////////////////////////
31:
32: /// <summary>
33: ///
34: /// </summary>
35: public abstract class ServiceApplication
36: {
37: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.ServiceApplication.Name;
38:
39: /// <summary/>
40: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
41:
42: /// <summary/>
43: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
44:
45: /// <summary/>
46: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
47:
48: /// <summary/>
49: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
50:
51: ////////////////////////////////////////////////////////////////////////////
52:
53: /// <summary>
54: ///
55: /// </summary>
56: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, string service)
57: {
58: var process = Ia.Ngn.Cl.Model.Business.Msmq.Process.ReadService;
59:
60: Enqueue(sender, process, service);
61: }
62:
63: ////////////////////////////////////////////////////////////////////////////
64:
65: /// <summary>
66: ///
67: /// </summary>
68: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
69: {
70: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
71:
72: if (!Ia.Ngn.Cl.Model.Data.Msmq.ServiceApplication.List.Contains(message.Serialization))
73: {
74: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
75: }
76: }
77:
78: ////////////////////////////////////////////////////////////////////////////
79:
80: /// <summary>
81: ///
82: /// </summary>
83: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
84: {
85: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
86: var switchVendor = Ia.Ngn.Cl.Model.Data.NetworkDesignDocument.SwitchVendorByService(message.Service);
87:
88: if (switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Nokia || switchVendor == Ia.Ngn.Cl.Model.Business.NetworkDesignDocument.Vendor.Huawei)
89: {
90: if (!Ia.Ngn.Cl.Model.Data.Msmq.ServiceApplication.List.Contains(message.Serialization))
91: {
92: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
93: }
94: }
95: }
96:
97: ////////////////////////////////////////////////////////////////////////////
98:
99: /// <summary>
100: ///
101: /// </summary>
102: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, int gatewayId)
103: {
104: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, gatewayId);
105:
106: if (!Ia.Ngn.Cl.Model.Data.Msmq.ServiceApplication.List.Contains(message.Serialization))
107: {
108: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
109: }
110: }
111:
112: ////////////////////////////////////////////////////////////////////////////
113: }
114:
115: ////////////////////////////////////////////////////////////////////////////
116: ////////////////////////////////////////////////////////////////////////////
117:
118: /// <summary>
119: ///
120: /// </summary>
121: public abstract class NetManagerApplication
122: {
123: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.NetManagerApplication.Name;
124:
125: /// <summary/>
126: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
127:
128: /// <summary/>
129: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
130:
131: /// <summary/>
132: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
133:
134: /// <summary/>
135: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
136:
137: ////////////////////////////////////////////////////////////////////////////
138:
139: /// <summary>
140: ///
141: /// </summary>
142: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
143: {
144: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
145:
146: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
147: }
148:
149: ////////////////////////////////////////////////////////////////////////////
150:
151: /// <summary>
152: ///
153: /// </summary>
154: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
155: {
156: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
157:
158: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
159: }
160:
161: ////////////////////////////////////////////////////////////////////////////
162: }
163:
164: ////////////////////////////////////////////////////////////////////////////
165: ////////////////////////////////////////////////////////////////////////////
166:
167: /// <summary>
168: ///
169: /// </summary>
170: public abstract class ServiceRequestApplication
171: {
172: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.ServiceRequestApplication.Name;
173:
174: /// <summary/>
175: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
176:
177: /// <summary/>
178: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
179:
180: /// <summary/>
181: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
182:
183: /// <summary/>
184: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
185:
186: ////////////////////////////////////////////////////////////////////////////
187:
188: /// <summary>
189: ///
190: /// </summary>
191: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
192: {
193: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
194:
195: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
196: }
197:
198: ////////////////////////////////////////////////////////////////////////////
199:
200: /// <summary>
201: ///
202: /// </summary>
203: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string accessName)
204: {
205: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, accessName);
206:
207: if (!Ia.Ngn.Cl.Model.Data.Msmq.ServiceRequestApplication.List.Contains(message.Serialization))
208: {
209: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
210: }
211: }
212:
213: ////////////////////////////////////////////////////////////////////////////
214: }
215:
216: ////////////////////////////////////////////////////////////////////////////
217: ////////////////////////////////////////////////////////////////////////////
218:
219: /// <summary>
220: ///
221: /// </summary>
222: public abstract class SpsApplication
223: {
224: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.SpsApplication.Name;
225:
226: /// <summary/>
227: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
228:
229: /// <summary/>
230: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
231:
232: /// <summary/>
233: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
234:
235: /// <summary/>
236: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
237:
238: ////////////////////////////////////////////////////////////////////////////
239:
240: /// <summary>
241: ///
242: /// </summary>
243: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
244: {
245: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
246:
247: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
248: }
249:
250: ////////////////////////////////////////////////////////////////////////////
251:
252: /// <summary>
253: ///
254: /// </summary>
255: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
256: {
257: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
258:
259: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
260: }
261:
262: ////////////////////////////////////////////////////////////////////////////
263: }
264:
265: ////////////////////////////////////////////////////////////////////////////
266: ////////////////////////////////////////////////////////////////////////////
267:
268: /// <summary>
269: ///
270: /// </summary>
271: public abstract class SoftXApplication
272: {
273: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.SoftXApplication.Name;
274:
275: /// <summary/>
276: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
277:
278: /// <summary/>
279: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
280:
281: /// <summary/>
282: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
283:
284: /// <summary/>
285: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
286:
287: ////////////////////////////////////////////////////////////////////////////
288:
289: /// <summary>
290: ///
291: /// </summary>
292: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
293: {
294: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
295:
296: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
297: }
298:
299: ////////////////////////////////////////////////////////////////////////////
300:
301: /// <summary>
302: ///
303: /// </summary>
304: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
305: {
306: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
307:
308: if (!Ia.Ngn.Cl.Model.Data.Msmq.SoftXApplication.List.Contains(message.Serialization))
309: {
310: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
311: }
312: }
313:
314: ////////////////////////////////////////////////////////////////////////////
315:
316: /// <summary>
317: ///
318: /// </summary>
319: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, bool overrideRouterDomainRestriction, Guid staffUserId)
320: {
321: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, overrideRouterDomainRestriction, staffUserId);
322:
323: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
324: }
325:
326: ////////////////////////////////////////////////////////////////////////////
327:
328: /// <summary>
329: ///
330: /// </summary>
331: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port, bool overrideRouterDomainRestriction, Guid staffUserId)
332: {
333: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port, overrideRouterDomainRestriction, staffUserId);
334:
335: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
336: }
337:
338: ////////////////////////////////////////////////////////////////////////////
339: }
340:
341: ////////////////////////////////////////////////////////////////////////////
342: ////////////////////////////////////////////////////////////////////////////
343:
344: /// <summary>
345: ///
346: /// </summary>
347: public abstract class AxeApplication
348: {
349: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.AxeApplication.Name;
350:
351: /// <summary/>
352: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
353:
354: /// <summary/>
355: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
356:
357: /// <summary/>
358: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
359:
360: /// <summary/>
361: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
362:
363: ////////////////////////////////////////////////////////////////////////////
364:
365: /// <summary>
366: ///
367: /// </summary>
368: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
369: {
370: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
371:
372: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
373: }
374:
375: ////////////////////////////////////////////////////////////////////////////
376:
377: /// <summary>
378: ///
379: /// </summary>
380: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
381: {
382: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
383:
384: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
385: }
386:
387: ////////////////////////////////////////////////////////////////////////////
388: }
389:
390: ////////////////////////////////////////////////////////////////////////////
391: ////////////////////////////////////////////////////////////////////////////
392:
393: /// <summary>
394: ///
395: /// </summary>
396: public abstract class AmsApplication
397: {
398: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.AmsApplication.Name;
399:
400: /// <summary/>
401: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
402:
403: /// <summary/>
404: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
405:
406: /// <summary/>
407: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
408:
409: /// <summary/>
410: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
411:
412: ////////////////////////////////////////////////////////////////////////////
413:
414: /// <summary>
415: ///
416: /// </summary>
417: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
418: {
419: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
420:
421: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
422: }
423:
424: ////////////////////////////////////////////////////////////////////////////
425:
426: /// <summary>
427: ///
428: /// </summary>
429: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
430: {
431: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
432:
433: if (!Ia.Ngn.Cl.Model.Data.Msmq.AmsApplication.List.Contains(message.Serialization))
434: {
435: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
436: }
437: }
438:
439: ////////////////////////////////////////////////////////////////////////////
440:
441: /// <summary>
442: ///
443: /// </summary>
444: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port)
445: {
446: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port);
447:
448: if (!Ia.Ngn.Cl.Model.Data.Msmq.AmsApplication.List.Contains(message.Serialization))
449: {
450: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
451: }
452: }
453:
454: ////////////////////////////////////////////////////////////////////////////
455:
456: /// <summary>
457: ///
458: /// </summary>
459: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, bool overrideRouterDomainRestriction, Guid staffUserId)
460: {
461: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, overrideRouterDomainRestriction, staffUserId);
462:
463: if (!Ia.Ngn.Cl.Model.Data.Msmq.AmsApplication.List.Contains(message.Serialization))
464: {
465: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
466: }
467: }
468:
469: ////////////////////////////////////////////////////////////////////////////
470:
471: /// <summary>
472: ///
473: /// </summary>
474: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port, bool overrideRouterDomainRestriction, Guid staffUserId)
475: {
476: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port, overrideRouterDomainRestriction, staffUserId);
477:
478: if (!Ia.Ngn.Cl.Model.Data.Msmq.AmsApplication.List.Contains(message.Serialization))
479: {
480: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
481: }
482: }
483:
484: ////////////////////////////////////////////////////////////////////////////
485: }
486:
487: ////////////////////////////////////////////////////////////////////////////
488: ////////////////////////////////////////////////////////////////////////////
489:
490: /// <summary>
491: ///
492: /// </summary>
493: public abstract class NceApplication
494: {
495: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.NceApplication.Name;
496:
497: /// <summary/>
498: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
499:
500: /// <summary/>
501: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
502:
503: /// <summary/>
504: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
505:
506: /// <summary/>
507: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
508:
509: ////////////////////////////////////////////////////////////////////////////
510:
511: /// <summary>
512: ///
513: /// </summary>
514: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
515: {
516: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
517:
518: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
519: }
520:
521: ////////////////////////////////////////////////////////////////////////////
522:
523: /// <summary>
524: ///
525: /// </summary>
526: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string serviceOrAccessName)
527: {
528: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, serviceOrAccessName);
529:
530: if (!Ia.Ngn.Cl.Model.Data.Msmq.NceApplication.List.Contains(message.Serialization))
531: {
532: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
533: }
534: }
535:
536: ////////////////////////////////////////////////////////////////////////////
537:
538: /// <summary>
539: ///
540: /// </summary>
541: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port)
542: {
543: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port);
544:
545: if (!Ia.Ngn.Cl.Model.Data.Msmq.NceApplication.List.Contains(message.Serialization))
546: {
547: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
548: }
549: }
550:
551: ////////////////////////////////////////////////////////////////////////////
552:
553: /// <summary>
554: ///
555: /// </summary>
556: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, bool overrideRouterDomainRestriction, Guid staffUserId)
557: {
558: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, overrideRouterDomainRestriction, staffUserId);
559:
560: if (!Ia.Ngn.Cl.Model.Data.Msmq.NceApplication.List.Contains(message.Serialization))
561: {
562: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
563: }
564: }
565:
566: ////////////////////////////////////////////////////////////////////////////
567:
568: /// <summary>
569: ///
570: /// </summary>
571: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port, bool overrideRouterDomainRestriction, Guid staffUserId)
572: {
573: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port, overrideRouterDomainRestriction, staffUserId);
574:
575: if (!Ia.Ngn.Cl.Model.Data.Msmq.NceApplication.List.Contains(message.Serialization))
576: {
577: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
578: }
579: }
580:
581: ////////////////////////////////////////////////////////////////////////////
582:
583: /// <summary>
584: ///
585: /// </summary>
586: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string msanDevId, int fn, int sn, int pn, string service)
587: {
588: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, msanDevId, fn, sn, pn, service);
589:
590: if (!Ia.Ngn.Cl.Model.Data.Msmq.NceApplication.List.Contains(message.Serialization))
591: {
592: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
593: }
594: }
595:
596: ////////////////////////////////////////////////////////////////////////////
597: }
598:
599: ////////////////////////////////////////////////////////////////////////////
600: ////////////////////////////////////////////////////////////////////////////
601:
602: /// <summary>
603: ///
604: /// </summary>
605: public abstract class ProvisionApplication
606: {
607: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.ProvisionApplication.Name;
608:
609: /// <summary/>
610: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
611:
612: /// <summary/>
613: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
614:
615: /// <summary/>
616: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
617:
618: /// <summary/>
619: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
620:
621: ////////////////////////////////////////////////////////////////////////////
622:
623: /// <summary>
624: ///
625: /// </summary>
626: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
627: {
628: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
629:
630: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
631: }
632:
633: ////////////////////////////////////////////////////////////////////////////
634:
635: /// <summary>
636: ///
637: /// </summary>
638: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
639: {
640: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
641:
642: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
643: }
644:
645: ////////////////////////////////////////////////////////////////////////////
646:
647: /// <summary>
648: ///
649: /// </summary>
650: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, bool overrideRouterDomainRestriction, Guid staffUserId)
651: {
652: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, overrideRouterDomainRestriction, staffUserId);
653:
654: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
655: }
656:
657: ////////////////////////////////////////////////////////////////////////////
658:
659: /// <summary>
660: ///
661: /// </summary>
662: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port, bool overrideRouterDomainRestriction, Guid staffUserId)
663: {
664: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port, overrideRouterDomainRestriction, staffUserId);
665:
666: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
667: }
668:
669: ////////////////////////////////////////////////////////////////////////////
670:
671: /// <summary>
672: ///
673: /// </summary>
674: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService supplementaryService, bool supplementaryServiceState, Guid staffUserId)
675: {
676: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, supplementaryService, supplementaryServiceState, staffUserId);
677:
678: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
679: }
680:
681: ////////////////////////////////////////////////////////////////////////////
682: }
683:
684: ////////////////////////////////////////////////////////////////////////////
685: ////////////////////////////////////////////////////////////////////////////
686:
687: /// <summary>
688: ///
689: /// </summary>
690: public abstract class OfnApplication
691: {
692: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.OfnApplication.Name;
693:
694: /// <summary/>
695: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
696:
697: /// <summary/>
698: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
699:
700: /// <summary/>
701: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
702:
703: /// <summary/>
704: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
705:
706: ////////////////////////////////////////////////////////////////////////////
707:
708: /// <summary>
709: ///
710: /// </summary>
711: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
712: {
713: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
714:
715: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
716: }
717:
718: ////////////////////////////////////////////////////////////////////////////
719:
720: /// <summary>
721: ///
722: /// </summary>
723: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string payload)
724: {
725: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, payload);
726:
727: if (!Ia.Ngn.Cl.Model.Data.Msmq.OfnApplication.List.Contains(message.Serialization))
728: {
729: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
730: }
731: }
732:
733: ////////////////////////////////////////////////////////////////////////////
734:
735: /// <summary>
736: ///
737: /// </summary>
738: public static void EnqueueSerializedPayload<T>(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, T t)
739: {
740: var payload = Ia.Ngn.Cl.Model.Business.Msmq.Message.Serialize<T>(t);
741:
742: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, payload);
743:
744: if (!Ia.Ngn.Cl.Model.Data.Msmq.OfnApplication.List.Contains(message.Serialization))
745: {
746: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
747: }
748: }
749:
750: ////////////////////////////////////////////////////////////////////////////
751: }
752:
753: ////////////////////////////////////////////////////////////////////////////
754: ////////////////////////////////////////////////////////////////////////////
755:
756: /// <summary>
757: ///
758: /// </summary>
759: public abstract class TelegramApplication
760: {
761: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.TelegramApplication.Name;
762:
763: /// <summary/>
764: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
765:
766: /// <summary/>
767: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
768:
769: /// <summary/>
770: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
771:
772: /// <summary/>
773: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
774:
775: ////////////////////////////////////////////////////////////////////////////
776:
777: /// <summary>
778: ///
779: /// </summary>
780: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
781: {
782: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
783:
784: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
785: }
786:
787: ////////////////////////////////////////////////////////////////////////////
788:
789: /// <summary>
790: ///
791: /// </summary>
792: public static void EnqueueSerializedPayload<T>(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, T t)
793: {
794: var payload = Ia.Ngn.Cl.Model.Business.Msmq.Message.Serialize<T>(t);
795:
796: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, payload);
797:
798: if (!Ia.Ngn.Cl.Model.Data.Msmq.TelegramApplication.List.Contains(message.Serialization))
799: {
800: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
801: }
802: }
803:
804: ////////////////////////////////////////////////////////////////////////////
805: }
806:
807: ////////////////////////////////////////////////////////////////////////////
808: ////////////////////////////////////////////////////////////////////////////
809:
810: /// <summary>
811: ///
812: /// </summary>
813: public abstract class SecretaryApplication
814: {
815: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.SecretaryApplication.Name;
816:
817: /// <summary/>
818: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
819:
820: /// <summary/>
821: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
822:
823: /// <summary/>
824: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
825:
826: /// <summary/>
827: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
828:
829: ////////////////////////////////////////////////////////////////////////////
830:
831: /// <summary>
832: ///
833: /// </summary>
834: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
835: {
836: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
837:
838: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
839: }
840:
841: ////////////////////////////////////////////////////////////////////////////
842:
843: /// <summary>
844: ///
845: /// </summary>
846: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, bool state)
847: {
848: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, state);
849:
850: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
851: }
852:
853: ////////////////////////////////////////////////////////////////////////////
854:
855: /// <summary>
856: ///
857: /// </summary>
858: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string serviceOrAccessName)
859: {
860: serviceOrAccessName = serviceOrAccessName.ToUpper();
861:
862: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, serviceOrAccessName);
863:
864: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
865: }
866:
867: ////////////////////////////////////////////////////////////////////////////
868:
869: /// <summary>
870: ///
871: /// </summary>
872: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, List<string> serviceOrAccessNameList)
873: {
874: foreach (string serviceOrAccessName in serviceOrAccessNameList)
875: {
876: Enqueue(sender, Ia.Ngn.Cl.Model.Business.Msmq.Process.ReadAccess, serviceOrAccessName);
877: }
878: }
879:
880: ////////////////////////////////////////////////////////////////////////////
881:
882: /// <summary>
883: ///
884: /// </summary>
885: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, int gatewayId)
886: {
887: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, gatewayId);
888:
889: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
890: }
891:
892: ////////////////////////////////////////////////////////////////////////////
893:
894: /// <summary>
895: ///
896: /// </summary>
897: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, Ia.Ngn.Cl.Model.Business.Service.SupplementaryService supplementaryService, bool supplementaryServiceState, Guid staffUserId)
898: {
899: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, supplementaryService, supplementaryServiceState, staffUserId);
900:
901: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
902: }
903:
904: ////////////////////////////////////////////////////////////////////////////
905:
906: /// <summary>
907: ///
908: /// </summary>
909: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, bool overrideRouterDomainRestriction, Guid staffUserId)
910: {
911: accessName = accessName.ToUpper();
912:
913: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, overrideRouterDomainRestriction, staffUserId);
914:
915: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
916: }
917:
918: ////////////////////////////////////////////////////////////////////////////
919:
920: /// <summary>
921: ///
922: /// </summary>
923: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port, bool overrideRouterDomainRestriction, Guid staffUserId)
924: {
925: accessName = accessName.ToUpper();
926:
927: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port, overrideRouterDomainRestriction, staffUserId);
928:
929: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
930: }
931:
932: ////////////////////////////////////////////////////////////////////////////
933:
934: /// <summary>
935: ///
936: /// </summary>
937: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service, string accessName, int port)
938: {
939: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service, accessName, port);
940:
941: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
942: }
943:
944: ////////////////////////////////////////////////////////////////////////////
945:
946: /// <summary>
947: ///
948: /// </summary>
949: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string msanDevId, int fn, int sn, int pn, string service)
950: {
951: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, msanDevId, fn, sn, pn, service);
952:
953: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
954: }
955:
956: ////////////////////////////////////////////////////////////////////////////
957: ////////////////////////////////////////////////////////////////////////////
958: }
959:
960: ////////////////////////////////////////////////////////////////////////////
961: ////////////////////////////////////////////////////////////////////////////
962:
963: /// <summary>
964: ///
965: /// </summary>
966: public abstract class EmailApplication
967: {
968: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.EmailApplication.Name;
969:
970: /// <summary/>
971: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
972:
973: /// <summary/>
974: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
975:
976: /// <summary/>
977: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
978:
979: /// <summary/>
980: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
981:
982: ////////////////////////////////////////////////////////////////////////////
983:
984: /// <summary>
985: ///
986: /// </summary>
987: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
988: {
989: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
990:
991: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
992: }
993:
994: ////////////////////////////////////////////////////////////////////////////
995: }
996:
997: ////////////////////////////////////////////////////////////////////////////
998: ////////////////////////////////////////////////////////////////////////////
999:
1000: /// <summary>
1001: ///
1002: /// </summary>
1003: public abstract class SdcApplication
1004: {
1005: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.SdcApplication.Name;
1006:
1007: /// <summary/>
1008: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
1009:
1010: /// <summary/>
1011: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
1012:
1013: /// <summary/>
1014: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
1015:
1016: /// <summary/>
1017: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
1018:
1019: ////////////////////////////////////////////////////////////////////////////
1020:
1021: /// <summary>
1022: ///
1023: /// </summary>
1024: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
1025: {
1026: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
1027:
1028: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
1029: }
1030:
1031: ////////////////////////////////////////////////////////////////////////////
1032: }
1033:
1034: ////////////////////////////////////////////////////////////////////////////
1035: ////////////////////////////////////////////////////////////////////////////
1036:
1037: /// <summary>
1038: ///
1039: /// </summary>
1040: public abstract class SchedulerApplication
1041: {
1042: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.SchedulerApplication.Name;
1043:
1044: /// <summary/>
1045: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
1046:
1047: /// <summary/>
1048: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
1049:
1050: /// <summary/>
1051: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
1052:
1053: /// <summary/>
1054: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
1055:
1056: ////////////////////////////////////////////////////////////////////////////
1057:
1058: /// <summary>
1059: ///
1060: /// </summary>
1061: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
1062: {
1063: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
1064:
1065: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
1066: }
1067:
1068: ////////////////////////////////////////////////////////////////////////////
1069: }
1070:
1071: ////////////////////////////////////////////////////////////////////////////
1072: ////////////////////////////////////////////////////////////////////////////
1073:
1074: /// <summary>
1075: ///
1076: /// </summary>
1077: public abstract class MdaaApplication
1078: {
1079: private static readonly string queueName = Ia.Ngn.Cl.Model.Business.Msmq.Application.MdaaApplication.Name;
1080:
1081: /// <summary/>
1082: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Dequeue { get { Ia.Cl.Model.Msmq.RecievePrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
1083:
1084: /// <summary/>
1085: public static Ia.Ngn.Cl.Model.Business.Msmq.Message Peek { get { Ia.Cl.Model.Msmq.PeekPrivate(queueName, out string label, out string body); return Ia.Ngn.Cl.Model.Business.Msmq.Message.Deserialize(body); } }
1086:
1087: /// <summary/>
1088: public static List<string> List { get { return Ia.Cl.Model.Msmq.PeekPrivateList(queueName); } }
1089:
1090: /// <summary/>
1091: public static long Count { get { return Ia.Cl.Model.Msmq.Count(queueName); } }
1092:
1093: ////////////////////////////////////////////////////////////////////////////
1094:
1095: /// <summary>
1096: ///
1097: /// </summary>
1098: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process)
1099: {
1100: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process);
1101:
1102: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
1103: }
1104:
1105: ////////////////////////////////////////////////////////////////////////////
1106:
1107: /// <summary>
1108: ///
1109: /// </summary>
1110: public static void Enqueue(Ia.Ngn.Cl.Model.Business.Msmq.Application sender, Ia.Ngn.Cl.Model.Business.Msmq.Process process, string service)
1111: {
1112: var message = new Ia.Ngn.Cl.Model.Business.Msmq.Message(sender, process, service);
1113:
1114: Ia.Cl.Model.Msmq.SendPrivate(queueName, message.Process.ToString(), message.Serialization);
1115: }
1116:
1117: ////////////////////////////////////////////////////////////////////////////
1118: }
1119:
1120: ////////////////////////////////////////////////////////////////////////////
1121: ////////////////////////////////////////////////////////////////////////////
1122: }
1123:
1124: ////////////////////////////////////////////////////////////////////////////
1125: ////////////////////////////////////////////////////////////////////////////
1126: }
1127: