authorization check for more Kafka operations

[dmaap/kafka11aaf.git] / src / main / java / org / onap / dmaap / kafkaAuthorize / PlainSaslServer1.java

diff --git a/src/main/java/org/onap/dmaap/kafkaAuthorize/PlainSaslServer1.java b/src/main/java/org/onap/dmaap/kafkaAuthorize/PlainSaslServer1.java
index f28671b..508d583 100644 (file)
--- a/src/main/java/org/onap/dmaap/kafkaAuthorize/PlainSaslServer1.java
+++ b/src/main/java/org/onap/dmaap/kafkaAuthorize/PlainSaslServer1.java
@@ -53,14 +53,9 @@ public class PlainSaslServer1 implements SaslServer {
 
        public static final String PLAIN_MECHANISM = "PLAIN";
 
-       private final JaasContext jaasContext;
-
        private boolean complete;
        private String authorizationID;
 
-       public PlainSaslServer1(JaasContext jaasContext) {
-               this.jaasContext = jaasContext;
-       }
 
        @Override
        public byte[] evaluateResponse(byte[] response) throws SaslException {
@@ -164,11 +159,7 @@ public class PlainSaslServer1 implements SaslServer {
                                throw new SaslException(
                                                String.format("Mechanism \'%s\' is not supported. Only PLAIN is supported.", mechanism));
 
-                       if (!(cbh instanceof SaslServerCallbackHandler))
-                               throw new SaslException(
-                                               "CallbackHandler must be of type SaslServerCallbackHandler, but it is: " + cbh.getClass());
-
-                       return new PlainSaslServer1(((SaslServerCallbackHandler) cbh).jaasContext());
+                       return new PlainSaslServer1();
                }
 
                @Override