Changeset 605 for raptor-client


Ignore:
Timestamp:
03/27/11 23:42:08 (9 years ago)
Author:
philsmart
Message:
 
Location:
raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor
Files:
2 edited
2 moved

Legend:

Unmodified
Added
Removed
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/attribute/filtering/AttrributeFilterEngine.java

    r598 r605  
    3636 *  
    3737 */ 
    38 public class AtrributeFilterEngine { 
     38public class AttrributeFilterEngine { 
    3939 
    4040        /* class logger. */ 
    41         private final Logger log = LoggerFactory.getLogger(AtrributeFilterEngine.class); 
     41        private final Logger log = LoggerFactory.getLogger(AttrributeFilterEngine.class); 
    4242 
    4343        /** 
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/registry/EventReleaseEngine.java

    r598 r605  
    2424import java.util.Set; 
    2525 
    26 import uk.ac.cardiff.raptor.attribute.filtering.AtrributeFilterEngine; 
     26import uk.ac.cardiff.raptor.attribute.filtering.AttrributeFilterEngine; 
    2727import uk.ac.cardiff.raptor.remoting.client.sei.ServiceEndpointInterface; 
    2828 
     
    4040public class EventReleaseEngine { 
    4141 
    42         private AtrributeFilterEngine attributeFilterEngine; 
     42        private AttrributeFilterEngine attributeFilterEngine; 
    4343        private ServiceEndpointInterface serviceEndpointInterface; 
    4444 
     
    6464                        if (shouldRelease) { 
    6565                                log.debug("Pushing {} entries to the Endpoint [{}]", filteredEntries.size(),endpoint.getServiceEndpoint()); 
    66                                 boolean releaseSuccess = serviceEndpointInterface.sendEvents(pushMessage,endpoint.getServiceEndpoint()); 
     66                                boolean releaseSuccess = getServiceEndpointInterface().sendEvents(pushMessage,endpoint.getServiceEndpoint()); 
    6767                                log.debug("Release to [{}] succeeded {}", endpoint.getServiceEndpoint(), releaseSuccess); 
    6868                                if (releaseSuccess == false) 
     
    112112        } 
    113113 
    114         public void setAttributeFilterEngine(AtrributeFilterEngine attributeFilterEngine) { 
     114        public void setAttributeFilterEngine(AttrributeFilterEngine attributeFilterEngine) { 
    115115                this.attributeFilterEngine = attributeFilterEngine; 
    116116        } 
    117117 
    118         public AtrributeFilterEngine getAttributeFilterEngine() { 
     118        public AttrributeFilterEngine getAttributeFilterEngine() { 
    119119                return attributeFilterEngine; 
    120120        } 
    121121 
     122        public void setServiceEndpointInterface(ServiceEndpointInterface serviceEndpointInterface) { 
     123                this.serviceEndpointInterface = serviceEndpointInterface; 
     124        } 
     125 
     126        public ServiceEndpointInterface getServiceEndpointInterface() { 
     127                return serviceEndpointInterface; 
     128        } 
     129 
    122130} 
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/remoting/client/impl/EventReleaseClientImpl.java

    r598 r605  
    2323        @Override 
    2424        public boolean release(List<Event> events, ClientMetadata clientMetadata) throws ReleaseFailureException{ 
    25                  
    26                 eventReleaseEngine.release(endpointRegistry, events, clientMetadata); 
    27                  
    28                 return true; 
     25                boolean success = eventReleaseEngine.release(endpointRegistry, events, clientMetadata);          
     26                return success; 
    2927                 
    3028        } 
  • raptor-client/trunk/src/main/java/uk/ac/cardiff/raptor/remoting/client/sei/impl/CxfServiceEndpointInterface.java

    r598 r605  
    1919import uk.ac.cardiff.raptor.remoting.client.sei.ServiceEndpointInterface; 
    2020import uk.ac.cardiff.sei.MultiUnitAggregator; 
    21 import uk.ac.cardiff.sei.UnitAggregator; 
    2221 
    23 public class CxfServiceEndpointImpl implements ServiceEndpointInterface { 
    24          
     22public class CxfServiceEndpointInterface implements ServiceEndpointInterface { 
     23 
    2524        /** Class logger */ 
    26         private final Logger log = LoggerFactory.getLogger(CxfServiceEndpointImpl.class); 
     25        private final Logger log = LoggerFactory.getLogger(CxfServiceEndpointInterface.class); 
    2726 
    2827        @Override 
    2928        public boolean sendEvents(EventPushMessage pushed, String endpointURL) { 
    3029                try { 
    31                     ClientProxyFactoryBean factory = new ClientProxyFactoryBean(); 
    32                     factory.setServiceClass(UnitAggregator.class); 
    33                     AegisDatabinding databinding = new AegisDatabinding(); 
     30                        ClientProxyFactoryBean factory = new ClientProxyFactoryBean(); 
     31                        factory.setServiceClass(MultiUnitAggregator.class); 
     32                        AegisDatabinding databinding = new AegisDatabinding(); 
    3433 
    35                     org.apache.cxf.aegis.AegisContext context = new org.apache.cxf.aegis.AegisContext(); 
    36                     context.setWriteXsiTypes(true); 
     34                        org.apache.cxf.aegis.AegisContext context = new org.apache.cxf.aegis.AegisContext(); 
     35                        context.setWriteXsiTypes(true); 
    3736 
    38                     Set<Class<?>> rootClasses = new HashSet<Class<?>>(); 
     37                        Set<Class<?>> rootClasses = new HashSet<Class<?>>(); 
    3938 
    40                     Set<String> overrides = new HashSet<String>(); 
    41                     overrides.add(ShibbolethEntry.class.getName()); 
    42                     overrides.add(AuthenticationEntry.class.getName()); 
    43                     overrides.add(UsageEntry.class.getName()); 
    44                     databinding.setOverrideTypes(overrides); 
     39                        Set<String> overrides = new HashSet<String>(); 
     40                        overrides.add(ShibbolethEntry.class.getName()); 
     41                        overrides.add(AuthenticationEntry.class.getName()); 
     42                        overrides.add(UsageEntry.class.getName()); 
     43                        databinding.setOverrideTypes(overrides); 
    4544 
    46                     for (String typeName : overrides) { 
    47                         Class c = null; 
    48                         try { 
    49                             c = ClassLoaderUtils.loadClass(typeName, TypeUtil.class); 
    50                         } catch (ClassNotFoundException e) { 
    51                             throw new DatabindingException("Could not find override type class: " + typeName, e); 
     45                        for (String typeName : overrides) { 
     46                                Class c = null; 
     47                                try { 
     48                                        c = ClassLoaderUtils.loadClass(typeName, TypeUtil.class); 
     49                                } catch (ClassNotFoundException e) { 
     50                                        throw new DatabindingException("Could not find override type class: " + typeName, e); 
     51                                } 
     52 
     53                                rootClasses.add(c); 
    5254                        } 
    5355 
    54                         rootClasses.add(c); 
    55                     } 
     56                        context.setRootClasses(rootClasses); 
     57                        databinding.setAegisContext(context); 
    5658 
    57                     context.setRootClasses(rootClasses); 
    58                     databinding.setAegisContext(context); 
     59                        factory.setAddress(endpointURL); 
     60                        factory.getServiceFactory().setDataBinding(databinding); 
    5961 
    60                     factory.setAddress(endpointURL); 
    61                     factory.getServiceFactory().setDataBinding(databinding); 
    62  
    63                     MultiUnitAggregator client = (MultiUnitAggregator) factory.create(); 
    64                     log.debug("Accessing the UA version " + client.getVersion()); 
    65                     Set<ShibbolethEntry> newEntries = new LinkedHashSet<ShibbolethEntry>(); 
    66                     client.addAuthentications(pushed); 
    67                     log.debug("Sent {} authentications", pushed.getEvents().size()); 
    68                     return true; 
     62                        MultiUnitAggregator client = (MultiUnitAggregator) factory.create(); 
     63                        log.debug("Accessing the endpoint version " + client.getVersion()); 
     64                        Set<ShibbolethEntry> newEntries = new LinkedHashSet<ShibbolethEntry>(); 
     65                        client.addAuthentications(pushed); 
     66                        log.debug("Sent {} events", pushed.getEvents().size()); 
     67                        return true; 
    6968                } catch (Exception e) { 
    70                     log.error("Could not send to endpoint [{}] ", endpointURL, e); 
    71                     // e.printStackTrace(); 
    72                     return false; 
     69                        log.error("Could not send to endpoint [{}] ", endpointURL, e); 
     70                        return false; 
    7371                } 
    7472 
    75             } 
     73        } 
    7674} 
    77  
    78  
Note: See TracChangeset for help on using the changeset viewer.