[prev in list] [next in list] [prev in thread] [next in thread] 

List:       openorb-devel
Subject:    [openorb-devel] fixed Recovering proxy failure Because comsumer(or supplier) unavailable
From:       <jiangwei_1976 () yahoo ! com ! cn>
Date:       2005-06-01 14:48:38
Message-ID: 20050601144838.93942.qmail () web15907 ! mail ! cnb ! yahoo ! com
[Download RAW message or body]

using 'unchecked_narrow ' instead of 'narrow' to defer
connect to comsumer(or supplier) till  Service started


		
___________________________________________________________ 
雅虎免费G邮箱-中国第一绝无垃圾邮件骚扰超大邮箱
http://cn.mail.yahoo.com/?id=77071

["notify.diff.txt" (text/plain)]

Index: src/main/org/openorb/notify/impl/ProxyPullConsumerImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/ProxyPullConsumerImpl.java,v
 retrieving revision 1.22
diff -u -w -b -r1.22 ProxyPullConsumerImpl.java
--- src/main/org/openorb/notify/impl/ProxyPullConsumerImpl.java	10 Feb 2004 21:16:30 \
                -0000	1.22
+++ src/main/org/openorb/notify/impl/ProxyPullConsumerImpl.java	1 Jun 2005 14:13:21 \
-0000 @@ -120,7 +120,7 @@
         if ( m_pssProxyConsumer.connected_supplier() != null )
         {
             m_puller.setSupplier(
-                        PullSupplierHelper.narrow( \
m_pssProxyConsumer.connected_supplier() ) ); +                        \
PullSupplierHelper.unchecked_narrow( m_pssProxyConsumer.connected_supplier() ) );  if \
( m_pssProxyConsumer.is_connected() )  {
                 m_puller.setConnectionActive( true );
@@ -131,7 +131,7 @@
         ReferenceInfo[] filters = m_pssProxyConsumer.filters();
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -643,7 +643,7 @@
                         new_filters[ j ] = filters[ j + 1 ];
                     }
                     m_pssProxyConsumer.filters( new_filters );
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  return;
                 }
                 new_filters[ i ] = filters[ i ];
@@ -672,7 +672,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();
Index: src/main/org/openorb/notify/impl/ProxyPullSupplierImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/ProxyPullSupplierImpl.java,v
 retrieving revision 1.22
diff -u -w -b -r1.22 ProxyPullSupplierImpl.java
--- src/main/org/openorb/notify/impl/ProxyPullSupplierImpl.java	10 Feb 2004 21:16:30 \
                -0000	1.22
+++ src/main/org/openorb/notify/impl/ProxyPullSupplierImpl.java	1 Jun 2005 14:12:48 \
-0000 @@ -128,7 +128,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -247,7 +247,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow(
+            return MappingFilterHelper.unchecked_narrow(
                    m_pssProxySupplier.mapping_filters()[ 1 ].reference );
         }
         catch ( java.lang.Throwable ex )
@@ -315,7 +315,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow(
+            return MappingFilterHelper.unchecked_narrow(
                   m_pssProxySupplier.mapping_filters() [ 0 ].reference );
         }
         catch ( java.lang.Throwable ex )
@@ -772,7 +772,7 @@
                         new_filters[ j ] = filters[ j + 1 ];
                     }
                     m_pssProxySupplier.filters( new_filters );
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  return;
                 }
                 new_filters[ i ] = filters[ i ];
@@ -801,7 +801,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();
Index: src/main/org/openorb/notify/impl/ProxyPushConsumerImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/ProxyPushConsumerImpl.java,v
 retrieving revision 1.17
diff -u -w -b -r1.17 ProxyPushConsumerImpl.java
--- src/main/org/openorb/notify/impl/ProxyPushConsumerImpl.java	10 Feb 2004 21:16:30 \
                -0000	1.17
+++ src/main/org/openorb/notify/impl/ProxyPushConsumerImpl.java	1 Jun 2005 14:11:33 \
-0000 @@ -126,7 +126,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -570,7 +570,7 @@
                     }
                     m_pssProxyConsumer.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -603,7 +603,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
 
Index: src/main/org/openorb/notify/impl/ProxyPushSupplierImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/ProxyPushSupplierImpl.java,v
 retrieving revision 1.21
diff -u -w -b -r1.21 ProxyPushSupplierImpl.java
--- src/main/org/openorb/notify/impl/ProxyPushSupplierImpl.java	22 Feb 2004 13:39:20 \
                -0000	1.21
+++ src/main/org/openorb/notify/impl/ProxyPushSupplierImpl.java	1 Jun 2005 14:12:14 \
-0000 @@ -182,7 +182,7 @@
         if ( m_pssProxySupplier.connected_consumer() != null )
         {
             final PushConsumer consumer =
-                    PushConsumerHelper.narrow( \
m_pssProxySupplier.connected_consumer() ); +                    \
PushConsumerHelper.unchecked_narrow( m_pssProxySupplier.connected_consumer() );  
             m_pusher.setConsumer( new AnyConsumerAdapter( consumer, \
m_consumerAdmin.getORB() ) );  m_pusher.setPropertiesRepository( \
m_propertiesRepository ); @@ -198,7 +198,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -387,7 +387,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[1].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[1].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -454,7 +454,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[0].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[0].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -802,7 +802,7 @@
                     }
                     m_pssProxySupplier.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -835,7 +835,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
 
Index: src/main/org/openorb/notify/impl/SequenceProxyPullConsumerImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/SequenceProxyPullConsumerImpl.java,v
 retrieving revision 1.20
diff -u -w -b -r1.20 SequenceProxyPullConsumerImpl.java
--- src/main/org/openorb/notify/impl/SequenceProxyPullConsumerImpl.java	10 Feb 2004 \
                21:53:31 -0000	1.20
+++ src/main/org/openorb/notify/impl/SequenceProxyPullConsumerImpl.java	1 Jun 2005 \
14:11:52 -0000 @@ -130,7 +130,7 @@
         if ( m_pssProxyConsumer.connected_supplier() != null )
         {
             m_puller.setSupplier(
-                    SequencePullSupplierHelper.narrow( \
m_pssProxyConsumer.connected_supplier() ) ); +                    \
SequencePullSupplierHelper.unchecked_narrow( m_pssProxyConsumer.connected_supplier() \
) );  
             if ( m_pssProxyConsumer.is_connected() )
             {
@@ -143,7 +143,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -647,7 +647,7 @@
                     }
                     m_pssProxyConsumer.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -681,7 +681,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
 
Index: src/main/org/openorb/notify/impl/SequenceProxyPullSupplierImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/SequenceProxyPullSupplierImpl.java,v
 retrieving revision 1.27
diff -u -w -b -r1.27 SequenceProxyPullSupplierImpl.java
--- src/main/org/openorb/notify/impl/SequenceProxyPullSupplierImpl.java	10 Feb 2004 \
                21:16:30 -0000	1.27
+++ src/main/org/openorb/notify/impl/SequenceProxyPullSupplierImpl.java	1 Jun 2005 \
14:11:03 -0000 @@ -129,7 +129,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -243,7 +243,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[1].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[1].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -313,7 +313,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[0].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[0].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -905,7 +905,7 @@
                     }
                     m_pssProxySupplier.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -939,7 +939,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
 
Index: src/main/org/openorb/notify/impl/SequenceProxyPushConsumerImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/SequenceProxyPushConsumerImpl.java,v
 retrieving revision 1.18
diff -u -w -b -r1.18 SequenceProxyPushConsumerImpl.java
--- src/main/org/openorb/notify/impl/SequenceProxyPushConsumerImpl.java	10 Feb 2004 \
                21:16:30 -0000	1.18
+++ src/main/org/openorb/notify/impl/SequenceProxyPushConsumerImpl.java	1 Jun 2005 \
14:13:06 -0000 @@ -128,7 +128,7 @@
         ReferenceInfo[] filters = m_pssProxyConsumer.filters();
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -591,7 +591,7 @@
                     }
                     m_pssProxyConsumer.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -623,7 +623,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();
Index: src/main/org/openorb/notify/impl/SequenceProxyPushSupplierImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/SequenceProxyPushSupplierImpl.java,v
 retrieving revision 1.21
diff -u -w -b -r1.21 SequenceProxyPushSupplierImpl.java
--- src/main/org/openorb/notify/impl/SequenceProxyPushSupplierImpl.java	19 Feb 2004 \
                07:21:28 -0000	1.21
+++ src/main/org/openorb/notify/impl/SequenceProxyPushSupplierImpl.java	1 Jun 2005 \
14:13:37 -0000 @@ -190,7 +190,7 @@
         if ( m_pssProxySupplier.connected_consumer() != null )
         {
             final SequencePushConsumer consumer =
-                    SequencePushConsumerHelper.narrow( \
m_pssProxySupplier.connected_consumer() ); +                    \
SequencePushConsumerHelper.unchecked_narrow( m_pssProxySupplier.connected_consumer() \
);  m_pusher.setConsumer(
                     new SequenceConsumerAdapter( consumer, m_consumerAdmin.getORB() \
) );  m_pusher.setPropertiesRepository( m_propertiesRepository );
@@ -204,7 +204,7 @@
         ReferenceInfo[] filters = m_pssProxySupplier.filters();
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -394,7 +394,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[1].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[1].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -462,7 +462,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[0].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[0].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -834,7 +834,7 @@
                         new_filters[ j ] = filters[ j + 1 ];
                     }
                     m_pssProxySupplier.filters( new_filters );
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  return;
                 }
                 new_filters[ i ] = filters[ i ];
@@ -863,7 +863,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();
Index: src/main/org/openorb/notify/impl/StructuredProxyPullConsumerImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/StructuredProxyPullConsumerImpl.java,v
 retrieving revision 1.19
diff -u -w -b -r1.19 StructuredProxyPullConsumerImpl.java
--- src/main/org/openorb/notify/impl/StructuredProxyPullConsumerImpl.java	10 Feb 2004 \
                21:16:30 -0000	1.19
+++ src/main/org/openorb/notify/impl/StructuredProxyPullConsumerImpl.java	1 Jun 2005 \
14:13:51 -0000 @@ -127,7 +127,7 @@
         // Recover the state
         if ( m_pssProxyConsumer.connected_supplier() != null )
         {
-            m_puller.setSupplier( StructuredPullSupplierHelper.narrow(
+            m_puller.setSupplier( StructuredPullSupplierHelper.unchecked_narrow(
                                       m_pssProxyConsumer.connected_supplier() ) );
             if ( m_pssProxyConsumer.is_connected() )
             {
@@ -139,7 +139,7 @@
         ReferenceInfo[] filters = m_pssProxyConsumer.filters();
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -649,7 +649,7 @@
                         new_filters[ j ] = filters[ j + 1 ];
                     }
                     m_pssProxyConsumer.filters( new_filters );
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  return;
                 }
 
@@ -681,7 +681,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
 
Index: src/main/org/openorb/notify/impl/StructuredProxyPullSupplierImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/StructuredProxyPullSupplierImpl.java,v
 retrieving revision 1.22
diff -u -w -b -r1.22 StructuredProxyPullSupplierImpl.java
--- src/main/org/openorb/notify/impl/StructuredProxyPullSupplierImpl.java	10 Feb 2004 \
                21:53:31 -0000	1.22
+++ src/main/org/openorb/notify/impl/StructuredProxyPullSupplierImpl.java	1 Jun 2005 \
14:12:29 -0000 @@ -134,7 +134,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -245,7 +245,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow(
+            return MappingFilterHelper.unchecked_narrow(
                                   m_pssProxySupplier.mapping_filters() [ 1 \
].reference );  }
         catch ( java.lang.Throwable ex )
@@ -317,7 +317,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[0].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[0].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -830,7 +830,7 @@
                     }
                     m_pssProxySupplier.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -865,7 +865,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();
Index: src/main/org/openorb/notify/impl/StructuredProxyPushConsumerImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/StructuredProxyPushConsumerImpl.java,v
 retrieving revision 1.20
diff -u -w -b -r1.20 StructuredProxyPushConsumerImpl.java
--- src/main/org/openorb/notify/impl/StructuredProxyPushConsumerImpl.java	22 Feb 2004 \
                13:39:20 -0000	1.20
+++ src/main/org/openorb/notify/impl/StructuredProxyPushConsumerImpl.java	1 Jun 2005 \
14:14:05 -0000 @@ -125,7 +125,7 @@
         ReferenceInfo[] filters = m_pssProxyConsumer.filters();
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -555,7 +555,7 @@
                     }
                     m_pssProxyConsumer.filters( new_filters );
 
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  
                     return;
                 }
@@ -589,7 +589,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();
Index: src/main/org/openorb/notify/impl/StructuredProxyPushSupplierImpl.java
===================================================================
RCS file: /cvsroot/openorb/NotificationService/src/main/org/openorb/notify/impl/StructuredProxyPushSupplierImpl.java,v
 retrieving revision 1.21
diff -u -w -b -r1.21 StructuredProxyPushSupplierImpl.java
--- src/main/org/openorb/notify/impl/StructuredProxyPushSupplierImpl.java	22 Feb 2004 \
                13:39:20 -0000	1.21
+++ src/main/org/openorb/notify/impl/StructuredProxyPushSupplierImpl.java	1 Jun 2005 \
14:14:19 -0000 @@ -184,7 +184,7 @@
         if ( m_pssProxySupplier.connected_consumer() != null )
         {
             final StructuredPushConsumer consumer =
-                    StructuredPushConsumerHelper.narrow( \
m_pssProxySupplier.connected_consumer() ); +                    \
StructuredPushConsumerHelper.unchecked_narrow( \
m_pssProxySupplier.connected_consumer() );  m_pusher.setConsumer(
                     new StructuredConsumerAdapter( consumer, \
m_consumerAdmin.getORB() ) );  m_pusher.setPropertiesRepository( \
m_propertiesRepository ); @@ -200,7 +200,7 @@
 
         for ( int i = 0; i < filters.length; i++ )
         {
-            m_queue.addFilter( FilterHelper.narrow( filters[ i ].reference ) );
+            m_queue.addFilter( FilterHelper.unchecked_narrow( filters[ i ].reference \
) );  }
     }
 
@@ -378,7 +378,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[1].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[1].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -445,7 +445,7 @@
     {
         try
         {
-            return MappingFilterHelper.narrow( \
m_pssProxySupplier.mapping_filters()[0].reference ); +            return \
MappingFilterHelper.unchecked_narrow( \
m_pssProxySupplier.mapping_filters()[0].reference );  }
         catch ( java.lang.Throwable ex )
         {
@@ -761,7 +761,7 @@
                         new_filters[ j ] = filters[ j + 1 ];
                     }
                     m_pssProxySupplier.filters( new_filters );
-                    m_queue.removeFilter( FilterHelper.narrow( filters[ i \
].reference ) ); +                    m_queue.removeFilter( \
FilterHelper.unchecked_narrow( filters[ i ].reference ) );  return;
                 }
                 new_filters[ i ] = filters[ i ];
@@ -790,7 +790,7 @@
             {
                 if ( filters[ i ].id == filter )
                 {
-                    return FilterHelper.narrow( filters[ i ].reference );
+                    return FilterHelper.unchecked_narrow( filters[ i ].reference );
                 }
             }
             throw new org.omg.CosNotifyFilter.FilterNotFound();


-------------------------------------------------------
This SF.Net email is sponsored by Yahoo.
Introducing Yahoo! Search Developer Network - Create apps using Yahoo!
Search APIs Find out how you can build Yahoo! directly into your own
Applications - visit http://developer.yahoo.net/?fr=offad-ysdn-ostg-q22005
_______________________________________________
openorb-devel mailing list
openorb-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/openorb-devel

[prev in list] [next in list] [prev in thread] [next in thread] 

Configure | About | News | Add a list | Sponsored by KoreLogic