Package org.apache.qpid.server.logging.subjects

Examples of org.apache.qpid.server.logging.subjects.ExchangeLogSubject

113
114
115
116
117
118
119
120
121
122
        _name = name;
        _durable = durable;
        _autoDelete = autoDelete;

        _id = id;
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(getType().getType(), name, durable));
    }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
        _durable = durable;
        _autoDelete = autoDelete;
        _ticket = ticket;

        _id = id;
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(String.valueOf(getTypeShortString()), String.valueOf(name), durable));
    }
View Full Code Here
113
114
115
116
117
118
119
120
121
122
        _ticket = ticket;

        _id = id;
        _qmfId = getConfigStore().createId();
        getConfigStore().addConfiguredObject(this);
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(String.valueOf(getTypeShortString()), String.valueOf(name), durable));
    }
View Full Code Here
137
138
139
140
141
142
143
144
145
146
        }
        catch (JMException e)
        {
            getLogger().error(e);
        }
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(String.valueOf(getTypeShortString()), String.valueOf(name), durable));
    }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
        _name = name;
        _durable = durable;
        _autoDelete = autoDelete;

        _id = id;
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(String.valueOf(getTypeShortString()), String.valueOf(name), durable));
    }
View Full Code Here
137
138
139
140
141
142
143
144
145
146
        }
        catch (JMException e)
        {
            getLogger().error(e);
        }
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(String.valueOf(getTypeShortString()), String.valueOf(name), durable));
    }
View Full Code Here
110
111
112
113
114
115
116
117
118
119
        _durable = durable;
        _autoDelete = autoDelete;
        _ticket = ticket;

        _id = id;
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.CREATED(String.valueOf(getTypeShortString()), String.valueOf(name), durable));
    }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
        _lifetimePolicy = MapValueConverter.getEnumAttribute(LifetimePolicy.class,
                                                                                org.apache.qpid.server.model.Exchange.LIFETIME_POLICY,
                                                                                attributes,
                                                                                LifetimePolicy.PERMANENT);
        _autoDelete = _lifetimePolicy != LifetimePolicy.PERMANENT;
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());


        // check ACL
        _virtualHost.getSecurityManager().authoriseCreateExchange(this);
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
        {
            deleted();
            throw e;
        }

        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        _bindingListener = new StateChangeListener<BindingImpl, State>()
        {
            @Override
            public void stateChanged(final BindingImpl binding, final State oldState, final State newState)
View Full Code Here
180
181
182
183
184
185
186
187
188
189
        }
        catch (JMException e)
        {
            getLogger().error(e);
        }
        _logSubject = new ExchangeLogSubject(this, this.getVirtualHost());

        // Log Exchange creation
        CurrentActor.get().message(ExchangeMessages.EXH_CREATED(String.valueOf(getType()), String.valueOf(name), durable));
    }
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.logging.subjects.ExchangeLogSubject

  • org.apache.qpid.server.exchange.AbstractExchange
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.