Examples of net.engio.mbassy.bus.error.IPublicationErrorHandler

net.engio.mbassy.bus.error.IPublicationErrorHandler
Publication error handlers are provided with a publication error every time an error occurs during message publication. A handler might fail with an exception, not be accessible because of the presence of a security manager or other reasons might lead to failures during the message publication process.
@author bennidiDate: 2/22/12




    @Test
    public void testExceptionInHandlerInvocation(){
        final AtomicInteger exceptionCount = new AtomicInteger(0);
        IPublicationErrorHandler ExceptionCounter = new IPublicationErrorHandler() {
            @Override
            public void handleError(PublicationError error) {
                exceptionCount.incrementAndGet();
            }
        };

View Full Code Here




    @Test
    public void testExceptionInHandlerInvocation(){
        final AtomicInteger exceptionCount = new AtomicInteger(0);
        IPublicationErrorHandler ExceptionCounter = new IPublicationErrorHandler() {
            @Override
            public void handleError(PublicationError error) {
                exceptionCount.incrementAndGet();
            }
        };

View Full Code Here

  private final Map<Object, Boolean> listeners = new WeakHashMap<>();


  public MBassadorEventPublisher() {
    super( BusConfiguration.SyncAsync() );


    this.addErrorHandler( new IPublicationErrorHandler()
    {
      public void handleError( PublicationError error ) {
        LOG.error( "Event handling error occurred: {}", error, error.getCause() );
      }
    } );

View Full Code Here

TOP

Related Classes of net.engio.mbassy.bus.error.IPublicationErrorHandler

com.foreach.across.core.events.MBassadorEventPublisher

net.engio.mbassy.MBassadorTest

net.engio.mbassy.SyncBusTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.