- final Set<String> cons = ti.getAllowedConsumers ();
- if ( cons != null )
- {
- out.println ( " read ACL: " );
- for ( String key : cons )
- {
- out.println ( "\t" + key );
- }
- }
- else
- {
- out.println ( " read ACL: <not active>" );
- }
- }
- }
- catch ( IOException x )
- {
- out.println ( "Problem with request: " + x.getMessage () );
- logger.error("IOException: ", x);
- }
- catch ( HttpObjectNotFoundException e )
- {
- out.println ( "Not found: " + e.getMessage () );
- logger.error("HttpObjectNotFoundException: ", e);
- }
- }
- else if ( parts[0].equals ( "create" ) )
- {
- try
- {
- final int partitions = Integer.parseInt ( parts[2] );
- final int replicas = Integer.parseInt ( parts[3] );
-
- tm.createTopic ( parts[1], "", partitions, replicas );
- }
- catch ( HttpException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("HttpException: ", e);
- }
- catch ( IOException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("IOException: ", e);
- }
- catch ( NumberFormatException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("NumberFormatException: ", e);
- }
- }
- else if ( parts[0].equals ( "grant" ) )
- {
- try
- {
- if ( parts[1].equals ( "write" ) )
- {
- tm.allowProducer ( parts[2], parts[3] );
- }
- else if ( parts[1].equals ( "read" ) )
- {
- tm.allowConsumer ( parts[2], parts[3] );
- }
- }
- catch ( HttpException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("HttpException: ", e);
- }
- catch ( IOException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("IOException: ", e);
- }
- }
- else if ( parts[0].equals ( "revoke" ) )
- {
- try
- {
- if ( parts[1].equals ( "write" ) )
- {
- tm.revokeProducer ( parts[2], parts[3] );
- }
- else if ( parts[1].equals ( "read" ) )
- {
- tm.revokeConsumer ( parts[2], parts[3] );
- }
- }
- catch ( HttpException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("HttpException: ", e);
- }
- catch ( IOException e )
- {
- out.println ( "Problem with request: " + e.getMessage () );
- logger.error("IOException: ", e);
- }
- }
- }
- finally
- {
- tm.close ();
- }
- }
+ tm.createTopic(parts[1], "", partitions, replicas);
+ } catch (HttpException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error(HTTP_EXCEPTION_MESSAGE, e);
+ } catch (IOException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error(IOEXCEPTION_MESSAGE, e);
+ } catch (NumberFormatException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error("NumberFormatException: ", e);
+ }
+ break;
+ case "grant":
+ try {
+ if (parts[1].equals("write")) {
+ tm.allowProducer(parts[2], parts[3]);
+ } else if (parts[1].equals("read")) {
+ tm.allowConsumer(parts[2], parts[3]);
+ }
+ } catch (HttpException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error(HTTP_EXCEPTION_MESSAGE, e);
+ } catch (IOException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error(IOEXCEPTION_MESSAGE, e);
+ }
+ break;
+ case "revoke":
+ try {
+ if (parts[1].equals("write")) {
+ tm.revokeProducer(parts[2], parts[3]);
+ } else if (parts[1].equals("read")) {
+ tm.revokeConsumer(parts[2], parts[3]);
+ }
+ } catch (HttpException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error(HTTP_EXCEPTION_MESSAGE, e);
+ } catch (IOException e) {
+ out.println(REQUEST_ERROR_MESSAGE + e.getMessage());
+ logger.error(IOEXCEPTION_MESSAGE, e);
+ }
+ break;
+ default:
+ throw new CommandNotReadyException("The command " + parts[0] + " is not available");
+ }
+ } finally {
+ tm.close();
+ }
+ }