Autodesk Map3d 2010 with WCF (III)

Author: Jonio, Dennis

The snippets below are an example for a client. It did take some time to research the parameters required for a long lived(8 hour) service. It turned out to be that two(2) parameters have to be set, InactivityTimeout and ReceiveTimeout. Needless to say these should match the service’s ServiceEndpoint configuration.

In general the way the service works is that you can send it data with any one(1) of three(3) different methods. I only employ one(1) of those methods in this case. If your application has “Subscribed” you will be sent via the callback method any and all output from the service. I really do not attempt to track the “state” of anything. As the book explains, and to say the least, state tracking is probably not the best way to expend your time and energy.

From Map3d's perspective the new, improved DataBridge is really a non issue. For all intent and purpose Map3d will see things the same way. I am sure that as time moves on the complexity of "if" and "case" statements will grow.
I plan on following this article with the complete DataBridge Version II.
Source code snippets for a client(C#):

+ expand sourceview plainprint?

1.      public static IByteSrvcWCallback SrvcHost;  
2.      public static ByteSrvcCallbackImpl callbackImpl;  
3.      public static DuplexChannelFactory<ibytesrvcwcallback> dcf;  
4.      public static Guid MyServicedName;  
5.      public static string MyPrefixForMap3dDQ = "MDADCLSSFYIO";  
6.      public static string AddressOfReliableSessionService = "net.tcp://localhost:9080/DataService";  
7.   
8.   
9.      public MainForm()  
10.      {  
11.          InitializeComponent();  
12.          NetTcpBinding ntb = new NetTcpBinding(SecurityMode.None, true);  
13.          ntb.ReliableSession.Enabled = true;  
14.          ntb.ReliableSession.Ordered = true;  
15.          ntb.ReliableSession.InactivityTimeout = new TimeSpan(0, 8, 0, 0);  
16.          ntb.ReceiveTimeout = new TimeSpan(0, 8, 0, 0);  
17.          callbackImpl = new ByteSrvcCallbackImpl();  
18.          InstanceContext ic = new InstanceContext(callbackImpl);  
19.          dcf = new DuplexChannelFactory<ibytesrvcwcallback>(  
20.                       ic,  
21.                       ntb,  
22.                       new EndpointAddress(AddressOfReliableSessionService));  
23.          SrvcHost = dcf.CreateChannel();  
24.          callbackImpl.OnGotControlPacket +=   
25. new ByteSrvcCallbackImpl.GotControlPacket(WCF_RcvdSrvcControlPacket);  
26.          MyServicedName = Guid.Empty;  
27.      }  
28.   
29.         void WCF_RcvdSrvcControlPacket(byte[] ba)  
30.         {  
31.             byte[] x = callbackImpl.ControlPacket;  
32.             //  
33.             //Here is the callback  
34.             //Do something useful with the data that the Service has sent to you  
35.            //  
36.         }  
37.   
38.         public int WCF_SendToMap3dDataBridge(byte[] ba)  
39.         {  
40.             return SrvcHost.DQPipedIn(MyPrefixForMap3dDQ, ba);  
41.         }  
42.   
43.         private void btnSUBSCRIBE_Click(object sender, EventArgs e)  
44.         {  
45.             try  
46.             {  
47.                 if (MyServicedName == Guid.Empty)  
48.                     MyServicedName = SrvcHost.Subscribe();  
49.             }  
50.             catch (EndpointNotFoundException _epnfX)  
51.             {  
52.                 AppendMessage("EndPoint ERROR: " + _epnfX.Message);  
53.             }  
54.             catch (System.Exception _eX)  
55.             {  
56.                 AppendMessage("ERROR: " + _eX.Message);  
57.             }  
58.         }  
59.   
60.         private void btnUNSUBSCRIBE_Click(object sender, EventArgs e)  
61.         {  
62.             try  
63.             {  
64.                 if (MyServicedName != Guid.Empty)  
65.                     SrvcHost.UnSubscribe(MyServicedName);  
66.                 MyServicedName = Guid.Empty;  
67.             }  
68.             catch (EndpointNotFoundException _epnfX)  
69.             {  
70.                 AppendMessage("EndPoint ERROR: " + _epnfX.Message);  
71.             }  
72.             catch (System.Exception _eX)  
73.             {  
74.                 AppendMessage("ERROR: " + _eX.Message);  
75.             }  
76.         }  
77. </ibytesrvcwcallback></ibytesrvcwcallback>  

     public static IByteSrvcWCallback SrvcHost;
     public static ByteSrvcCallbackImpl callbackImpl;
     public static DuplexChannelFactory dcf;
     public static Guid MyServicedName;
     public static string MyPrefixForMap3dDQ = "MDADCLSSFYIO";
     public static string AddressOfReliableSessionService = "net.tcp://localhost:9080/DataService";


     public MainForm()
     {
         InitializeComponent();
         NetTcpBinding ntb = new NetTcpBinding(SecurityMode.None, true);
         ntb.ReliableSession.Enabled = true;
         ntb.ReliableSession.Ordered = true;
         ntb.ReliableSession.InactivityTimeout = new TimeSpan(0, 8, 0, 0);
         ntb.ReceiveTimeout = new TimeSpan(0, 8, 0, 0);
         callbackImpl = new ByteSrvcCallbackImpl();
         InstanceContext ic = new InstanceContext(callbackImpl);
         dcf = new DuplexChannelFactory(
                      ic,
                      ntb,
                      new EndpointAddress(AddressOfReliableSessionService));
         SrvcHost = dcf.CreateChannel();
         callbackImpl.OnGotControlPacket += 
new ByteSrvcCallbackImpl.GotControlPacket(WCF_RcvdSrvcControlPacket);
         MyServicedName = Guid.Empty;
     }

        void WCF_RcvdSrvcControlPacket(byte[] ba)
        {
            byte[] x = callbackImpl.ControlPacket;
            //
            //Here is the callback
            //Do something useful with the data that the Service has sent to you
           //
        }

        public int WCF_SendToMap3dDataBridge(byte[] ba)
        {
            return SrvcHost.DQPipedIn(MyPrefixForMap3dDQ, ba);
        }

        private void btnSUBSCRIBE_Click(object sender, EventArgs e)
        {
            try
            {
                if (MyServicedName == Guid.Empty)
                    MyServicedName = SrvcHost.Subscribe();
            }
            catch (EndpointNotFoundException _epnfX)
            {
                AppendMessage("EndPoint ERROR: " + _epnfX.Message);
            }
            catch (System.Exception _eX)
            {
                AppendMessage("ERROR: " + _eX.Message);
            }
        }

        private void btnUNSUBSCRIBE_Click(object sender, EventArgs e)
        {
            try
            {
                if (MyServicedName != Guid.Empty)
                    SrvcHost.UnSubscribe(MyServicedName);
                MyServicedName = Guid.Empty;
            }
            catch (EndpointNotFoundException _epnfX)
            {
                AppendMessage("EndPoint ERROR: " + _epnfX.Message);
            }
            catch (System.Exception _eX)
            {
                AppendMessage("ERROR: " + _eX.Message);
            }
        }