/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.qpid.proton4j.engine.impl;

import org.apache.qpid.proton4j.amqp.transactions.Declare;
import org.apache.qpid.proton4j.amqp.transactions.Declared;
import org.apache.qpid.proton4j.amqp.transactions.Discharge;
import org.apache.qpid.proton4j.amqp.transport.Role;
import org.apache.qpid.proton4j.engine.AsyncEvent;
import org.apache.qpid.proton4j.engine.EventHandler;

/**
 * Proton Coordinator link implementation.
 */
public class ProtonCoordinator extends ProtonLink<ProtonCoordinator> {

    // TODO - Should be two ends of a coordinator, sender and receiver
    //        one side drives the declare and discharge and the other
    //        handles those requests for TX boundaries.

    protected ProtonCoordinator(ProtonSession session, String name) {
        super(session, name);
    }

    @Override
    public int getCredit() {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public Role getRole() {
        return Role.SENDER;
    }

    @Override
    protected ProtonCoordinator self() {
        return this;
    }

    @Override
    protected ProtonLinkCreditState<?> getCreditState() {
        // TODO Auto-generated method stub
        return null;
    }

    public void declare(byte[] txnId) {

    }

    public void discharge(byte[] txnId, boolean failed) {

    }

    // TODO - Possible event points to handle declare of a TX and the response, and the discharge of a TX

    public ProtonCoordinator declareHandler(EventHandler<AsyncEvent<Declare>> remoteDeclareHandler) {
        return this;
    }

    public ProtonCoordinator declaredHandler(EventHandler<AsyncEvent<Declared>> remoteDeclaredHandler) {
        return this;
    }

    public ProtonCoordinator dischargeHandler(EventHandler<AsyncEvent<Discharge>> remoteDischargeHandler) {
        return this;
    }
}

@@ -1500,16 +1500,161 @@
 ndaries.
+%0A    //%0A    // CoordinatorClient -%3E CoordinatorServer%0A    // CoordinatorSource -%3E CoordinatorSink%0A    // CoordinatorSender -%3E CoordinatorReceiver
 %0A%0A    pr
@@ -2192,28 +2192,16 @@
 declare(
-byte%5B%5D txnId
 ) %7B%0A%0A   

Fix declare definition and add some naming options