geode-core/src/main/java/org/apache/geode/management/internal/beans/BeanUtilFuncs.java - geode - Git at Google

 /*
  * 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.geode.management.internal.beans;

 import java.io.BufferedReader;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.File;
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.RandomAccessFile;
 import java.util.zip.GZIPInputStream;
 import java.util.zip.GZIPOutputStream;

 import org.apache.geode.distributed.internal.DistributionConfig;
 import org.apache.geode.management.GemFireProperties;

 /**
  * Various Utility Functions to be used by MBeans
  */
 public class BeanUtilFuncs {

   /**
    * returns the tail of the log file
    *
    * @return tail of the log file
    */
   public static String tailSystemLog(File logFile, final int numLines) throws IOException {
     if (logFile == null || logFile.equals(new File(""))) {
       return null;
     }
     int maxBuffer = 65500; // DataOutput.writeUTF will only accept 65535 bytes
     long fileLength = logFile.length();
     if (fileLength == 0) {
       return null;
     }
     byte[] buffer = (fileLength > maxBuffer) ? new byte[maxBuffer] : new byte[(int) fileLength];

     int readSize = buffer.length;
     RandomAccessFile f = new RandomAccessFile(logFile, "r");

     int linesRead = 0;
     long seekPosition = fileLength - readSize;
     StringBuilder returnStr = new StringBuilder();
     StringBuilder workingString = new StringBuilder();
     String separator = System.getProperty("line.separator");

     while (linesRead < numLines) {

       f.seek(seekPosition);
       f.read(buffer, 0, readSize);

       workingString.insert(0, new String(buffer, 0, readSize));

       String[] splits = workingString.toString().split("\\r?\\n");

       // The first element may be part of a line, so we don't count that
       // but we need to save it for the next time around.
       if (splits.length > 1) {
         for (int i = splits.length - 1; i > 0; i--) {
           returnStr.insert(0, separator).insert(0, splits[i]);
           if (++linesRead >= numLines) {
             break;
           }
         }
       }

       if (seekPosition == 0 && linesRead < numLines) {
         returnStr.insert(0, separator).insert(0, splits[0]);
         break;
       }

       workingString = new StringBuilder(splits[0]);

       if (readSize < seekPosition) {
         seekPosition = seekPosition - readSize;
       } else {
         readSize = (int) seekPosition;
         seekPosition = 0;
       }
     }

     f.close();

     returnStr.insert(0, separator).insert(0, "SystemLog:");

     return returnStr.toString();
   }

   /**
    * @return tail of log
    */
   public static String tailSystemLog(DistributionConfig sc, final int numLines) throws IOException {
     File logFile = sc.getLogFile();
     if (logFile == null || logFile.equals(new File(""))) {
       return null;
     }
     if (!logFile.isAbsolute()) {
       logFile = new File(logFile.getAbsolutePath());
     }
     return tailSystemLog(logFile, numLines);
   }

   public static GemFireProperties initGemfireProperties(DistributionConfig config) {
     String memberGroups = "";
     String configFile = null;
     String includeFile = null;

     GemFireProperties gemFirePropertyData = new GemFireProperties();

     gemFirePropertyData.setMemberName(config.getName());
     gemFirePropertyData.setMemberGroups(memberGroups);
     gemFirePropertyData.setMcastPort(config.getMcastPort());
     gemFirePropertyData.setMcastAddress(config.getMcastAddress().getHostAddress());
     gemFirePropertyData.setBindAddress(config.getBindAddress());
     gemFirePropertyData.setTcpPort(config.getTcpPort());
     gemFirePropertyData.setCacheXMLFile(config.getCacheXmlFile().getAbsolutePath());
     gemFirePropertyData.setConfigFile(configFile);
     gemFirePropertyData.setMcastTTL(config.getMcastTtl());
     gemFirePropertyData.setServerBindAddress(config.getServerBindAddress());
     gemFirePropertyData.setLocators(config.getLocators());
     gemFirePropertyData.setStartLocator(config.getStartLocator());
     gemFirePropertyData.setLogFile(config.getLogFile().getAbsolutePath());
     gemFirePropertyData.setLogLevel(config.getLogLevel());
     gemFirePropertyData.setStatisticSamplingEnabled(config.getStatisticSamplingEnabled());

     gemFirePropertyData.setStatisticArchiveFile(config.getStatisticArchiveFile().getAbsolutePath());
     gemFirePropertyData.setIncludeFile(includeFile);
     gemFirePropertyData.setAckWaitThreshold(config.getAckWaitThreshold());

     gemFirePropertyData.setAckSevereAlertThreshold(config.getAckSevereAlertThreshold());

     gemFirePropertyData.setArchiveFileSizeLimit(config.getArchiveFileSizeLimit());

     gemFirePropertyData.setArchiveDiskSpaceLimit(config.getArchiveDiskSpaceLimit());
     gemFirePropertyData.setLogFileSizeLimit(config.getLogFileSizeLimit());
     gemFirePropertyData.setLogDiskSpaceLimit(config.getLogDiskSpaceLimit());

     gemFirePropertyData.setClusterSSLEnabled(config.getClusterSSLEnabled());
     gemFirePropertyData.setClusterSSLCiphers(config.getClusterSSLCiphers());
     gemFirePropertyData.setClusterSSLProtocols(config.getClusterSSLProtocols());
     gemFirePropertyData
         .setClusterSSLRequireAuthentication(config.getClusterSSLRequireAuthentication());
     gemFirePropertyData.setClusterSSLKeyStore(config.getClusterSSLKeyStore());
     gemFirePropertyData.setClusterSSLKeyStoreType(config.getClusterSSLKeyStoreType());
     gemFirePropertyData.setClusterSSLKeyStorePassword(config.getClusterSSLKeyStorePassword());
     gemFirePropertyData.setClusterSSLTrustStore(config.getClusterSSLTrustStore());
     gemFirePropertyData.setClusterSSLTrustStorePassword(config.getClusterSSLTrustStorePassword());

     gemFirePropertyData.setServerSSLEnabled(config.getServerSSLEnabled());
     gemFirePropertyData.setServerSSLCiphers(config.getServerSSLCiphers());
     gemFirePropertyData.setServerSSLProtocols(config.getServerSSLProtocols());
     gemFirePropertyData
         .setServerSSLRequireAuthentication(config.getServerSSLRequireAuthentication());
     gemFirePropertyData.setServerSSLKeyStore(config.getServerSSLKeyStore());
     gemFirePropertyData.setServerSSLKeyStoreType(config.getServerSSLKeyStoreType());
     gemFirePropertyData.setServerSSLKeyStorePassword(config.getServerSSLKeyStorePassword());
     gemFirePropertyData.setServerSSLTrustStore(config.getServerSSLTrustStore());
     gemFirePropertyData.setServerSSLTrustStorePassword(config.getServerSSLTrustStorePassword());

     gemFirePropertyData.setGatewaySSLEnabled(config.getGatewaySSLEnabled());
     gemFirePropertyData.setGatewaySSLCiphers(config.getGatewaySSLCiphers());
     gemFirePropertyData.setGatewaySSLProtocols(config.getGatewaySSLProtocols());
     gemFirePropertyData
         .setGatewaySSLRequireAuthentication(config.getGatewaySSLRequireAuthentication());
     gemFirePropertyData.setGatewaySSLKeyStore(config.getGatewaySSLKeyStore());
     gemFirePropertyData.setGatewaySSLKeyStoreType(config.getGatewaySSLKeyStoreType());
     gemFirePropertyData.setGatewaySSLKeyStorePassword(config.getGatewaySSLKeyStorePassword());
     gemFirePropertyData.setGatewaySSLTrustStore(config.getGatewaySSLTrustStore());
     gemFirePropertyData.setGatewaySSLTrustStorePassword(config.getGatewaySSLTrustStorePassword());

     gemFirePropertyData.setJmxManagerSSLEnabled(config.getJmxManagerSSLEnabled());
     gemFirePropertyData.setJmxManagerSSLCiphers(config.getJmxManagerSSLCiphers());
     gemFirePropertyData.setJmxManagerSSLProtocols(config.getJmxManagerSSLProtocols());
     gemFirePropertyData
         .setJmxManagerSSLRequireAuthentication(config.getJmxManagerSSLRequireAuthentication());
     gemFirePropertyData.setJmxManagerSSLKeyStore(config.getJmxManagerSSLKeyStore());
     gemFirePropertyData.setJmxManagerSSLKeyStoreType(config.getJmxManagerSSLKeyStoreType());
     gemFirePropertyData.setJmxManagerSSLKeyStorePassword(config.getJmxManagerSSLKeyStorePassword());
     gemFirePropertyData.setJmxManagerSSLTrustStore(config.getJmxManagerSSLTrustStore());
     gemFirePropertyData
         .setJmxManagerSSLTrustStorePassword(config.getJmxManagerSSLTrustStorePassword());

     gemFirePropertyData.setHttpServiceSSLEnabled(config.getHttpServiceSSLEnabled());
     gemFirePropertyData.setHttpServiceSSLCiphers(config.getHttpServiceSSLCiphers());
     gemFirePropertyData.setHttpServiceSSLProtocols(config.getHttpServiceSSLProtocols());
     gemFirePropertyData
         .setHttpServiceSSLRequireAuthentication(config.getHttpServiceSSLRequireAuthentication());
     gemFirePropertyData.setHttpServiceSSLKeyStore(config.getHttpServiceSSLKeyStore());
     gemFirePropertyData.setHttpServiceSSLKeyStoreType(config.getHttpServiceSSLKeyStoreType());
     gemFirePropertyData
         .setHttpServiceSSLKeyStorePassword(config.getHttpServiceSSLKeyStorePassword());
     gemFirePropertyData.setHttpServiceSSLTrustStore(config.getHttpServiceSSLTrustStore());
     gemFirePropertyData
         .setHttpServiceSSLTrustStorePassword(config.getHttpServiceSSLTrustStorePassword());

     gemFirePropertyData.setSocketLeaseTime(config.getSocketLeaseTime());

     gemFirePropertyData.setSocketBufferSize(config.getSocketBufferSize());
     gemFirePropertyData.setMcastSendBufferSize(config.getMcastSendBufferSize());
     gemFirePropertyData.setMcastRecvBufferSize(config.getMcastRecvBufferSize());

     gemFirePropertyData.setMcastByteAllowance(config.getMcastFlowControl().getByteAllowance());
     gemFirePropertyData
         .setMcastRechargeThreshold(config.getMcastFlowControl().getRechargeThreshold());
     gemFirePropertyData.setMcastRechargeBlockMs(config.getMcastFlowControl().getRechargeBlockMs());
     gemFirePropertyData.setUdpFragmentSize(config.getUdpFragmentSize());

     gemFirePropertyData.setUdpRecvBufferSize(config.getUdpRecvBufferSize());
     gemFirePropertyData.setDisableTcp(config.getDisableTcp());

     gemFirePropertyData.setEnableTimeStatistics(config.getEnableTimeStatistics());

     gemFirePropertyData
         .setEnableNetworkPartitionDetection(config.getEnableNetworkPartitionDetection());

     gemFirePropertyData.setMemberTimeout(config.getMemberTimeout());
     gemFirePropertyData.setMembershipPortRange(config.getMembershipPortRange());
     gemFirePropertyData.setConserveSockets(config.getConserveSockets());

     gemFirePropertyData.setRoles(config.getRoles());
     gemFirePropertyData.setMaxWaitTimeForReconnect(config.getMaxWaitTimeForReconnect());

     gemFirePropertyData.setMaxNumReconnectTries(config.getMaxNumReconnectTries());

     gemFirePropertyData.setAsyncDistributionTimeout(config.getAsyncDistributionTimeout());

     gemFirePropertyData.setAsyncQueueTimeout(config.getAsyncQueueTimeout());
     gemFirePropertyData.setAsyncMaxQueueSize(config.getAsyncMaxQueueSize());
     gemFirePropertyData.setClientConflation(config.getClientConflation());

     gemFirePropertyData.setDurableClientId(config.getDurableClientId());
     gemFirePropertyData.setDurableClientTimeout(config.getDurableClientTimeout());
     gemFirePropertyData.setSecurityClientAuthInit(config.getSecurityClientAuthInit());
     gemFirePropertyData.setSecurityClientAuthenticator(config.getSecurityClientAuthenticator());
     gemFirePropertyData.setSecurityClientDHAlgo(config.getSecurityClientDHAlgo());
     gemFirePropertyData.setSecurityPeerAuthInit(config.getSecurityPeerAuthInit());
     gemFirePropertyData.setSecurityPeerAuthenticator(config.getSecurityPeerAuthenticator());
     gemFirePropertyData.setSecurityClientAccessor(config.getSecurityClientAccessor());
     gemFirePropertyData.setSecurityClientAccessorPP(config.getSecurityClientAccessorPP());
     gemFirePropertyData.setSecurityLogLevel(config.getSecurityLogLevel());

     gemFirePropertyData.setSecurityLogFile(config.getSecurityLogFile().getAbsolutePath());

     gemFirePropertyData.setSecurityPeerMembershipTimeout(config.getSecurityPeerMembershipTimeout());

     gemFirePropertyData.setRemoveUnresponsiveClient(config.getRemoveUnresponsiveClient());

     gemFirePropertyData.setDeltaPropagation(config.getDeltaPropagation());
     gemFirePropertyData.setRedundancyZone(config.getRedundancyZone());
     gemFirePropertyData.setEnforceUniqueHost(config.getEnforceUniqueHost());

     gemFirePropertyData.setStatisticSampleRate(config.getStatisticSampleRate());
     gemFirePropertyData.setUdpSendBufferSize(config.getUdpSendBufferSize());

     gemFirePropertyData.setJmxManager(config.getJmxManager());
     gemFirePropertyData.setJmxManagerStart(config.getJmxManagerStart());
     gemFirePropertyData.setJmxManagerPort(config.getJmxManagerPort());
     gemFirePropertyData.setJmxManagerBindAddress(config.getJmxManagerBindAddress());
     gemFirePropertyData.setJmxManagerHostnameForClients(config.getJmxManagerHostnameForClients());
     gemFirePropertyData.setJmxManagerPasswordFile(config.getJmxManagerPasswordFile());
     gemFirePropertyData.setJmxManagerAccessFile(config.getJmxManagerAccessFile());
     gemFirePropertyData.setJmxManagerHttpPort(config.getJmxManagerHttpPort());
     gemFirePropertyData.setJmxManagerUpdateRate(config.getJmxManagerUpdateRate());
     gemFirePropertyData.setHttpServicePort(config.getHttpServicePort());
     gemFirePropertyData.setHttpServiceBindAddress(config.getHttpServiceBindAddress());
     gemFirePropertyData.setStartDevRestApi(config.getStartDevRestApi());

     gemFirePropertyData.setSSLCiphers(config.getSSLCiphers());
     gemFirePropertyData
         .setSecurableCommunicationChannel(config.getSecurableCommunicationChannels());
     gemFirePropertyData
         .setSSLWebServiceRequireAuthentication(config.getSSLWebRequireAuthentication());
     gemFirePropertyData.setSSLKeyStore(config.getSSLKeyStore());
     gemFirePropertyData.setSSLKeyStoreType(config.getSSLKeyStoreType());
     gemFirePropertyData.setSSLKeyStorePassword(config.getSSLKeyStorePassword());

     gemFirePropertyData.setSSLTrustStore(config.getSSLTrustStore());
     gemFirePropertyData.setSSLTrustStorePassword(config.getSSLTrustStorePassword());
     gemFirePropertyData.setSSLTrustStoreType(config.getSSLTrustStoreType());

     gemFirePropertyData.setClusterSSLAlias(config.getClusterSSLAlias());
     gemFirePropertyData.setServerSSLAlias(config.getServerSSLAlias());
     gemFirePropertyData.setJmxSSLAlias(config.getJMXSSLAlias());
     gemFirePropertyData.setGatewaySSLAlias(config.getGatewaySSLAlias());
     gemFirePropertyData.setLocatorSSLAlias(config.getLocatorSSLAlias());
     gemFirePropertyData.setHttpServiceSSLAlias(config.getHTTPServiceSSLAlias());
     gemFirePropertyData.setSSLDefaultAlias(config.getSSLDefaultAlias());

     return gemFirePropertyData;
   }

   /**
    * Compresses a given String. It is encoded using ISO-8859-1, So any decompression of the
    * compressed string should also use ISO-8859-1
    *
    * @param str String to be compressed.
    * @return compressed bytes
    */
   public static byte[] compress(String str) throws IOException {
     if (str == null || str.length() == 0) {
       return null;
     }
     ByteArrayOutputStream out = new ByteArrayOutputStream();
     GZIPOutputStream gzip = new GZIPOutputStream(out);
     gzip.write(str.getBytes("UTF-8"));
     gzip.close();
     byte[] outBytes = out.toByteArray();
     return outBytes;
   }

   /**
    * @param bytes bytes to be decompressed
    * @return a decompressed String
    */
   public static String decompress(byte[] bytes) throws IOException {
     if (bytes == null || bytes.length == 0) {
       return null;
     }
     GZIPInputStream gis = new GZIPInputStream(new ByteArrayInputStream(bytes));
     BufferedReader bf = new BufferedReader(new InputStreamReader(gis, "UTF-8"));
     String outStr = "";
     String line;
     while ((line = bf.readLine()) != null) {
       outStr += line;
     }
     return outStr;
   }

 }
	/*
	* 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.geode.management.internal.beans;

	import java.io.BufferedReader;
	import java.io.ByteArrayInputStream;
	import java.io.ByteArrayOutputStream;
	import java.io.File;
	import java.io.IOException;
	import java.io.InputStreamReader;
	import java.io.RandomAccessFile;
	import java.util.zip.GZIPInputStream;
	import java.util.zip.GZIPOutputStream;

	import org.apache.geode.distributed.internal.DistributionConfig;
	import org.apache.geode.management.GemFireProperties;

	/**
	* Various Utility Functions to be used by MBeans
	*/
	public class BeanUtilFuncs {

	/**
	* returns the tail of the log file
	*
	* @return tail of the log file
	*/
	public static String tailSystemLog(File logFile, final int numLines) throws IOException {
	if (logFile == null \|\| logFile.equals(new File(""))) {
	return null;
	}
	int maxBuffer = 65500; // DataOutput.writeUTF will only accept 65535 bytes
	long fileLength = logFile.length();
	if (fileLength == 0) {
	return null;
	}
	byte[] buffer = (fileLength > maxBuffer) ? new byte[maxBuffer] : new byte[(int) fileLength];

	int readSize = buffer.length;
	RandomAccessFile f = new RandomAccessFile(logFile, "r");

	int linesRead = 0;
	long seekPosition = fileLength - readSize;
	StringBuilder returnStr = new StringBuilder();
	StringBuilder workingString = new StringBuilder();
	String separator = System.getProperty("line.separator");

	while (linesRead < numLines) {

	f.seek(seekPosition);
	f.read(buffer, 0, readSize);

	workingString.insert(0, new String(buffer, 0, readSize));

	String[] splits = workingString.toString().split("\\r?\\n");

	// The first element may be part of a line, so we don't count that
	// but we need to save it for the next time around.
	if (splits.length > 1) {
	for (int i = splits.length - 1; i > 0; i--) {
	returnStr.insert(0, separator).insert(0, splits[i]);
	if (++linesRead >= numLines) {
	break;
	}
	}
	}

	if (seekPosition == 0 && linesRead < numLines) {
	returnStr.insert(0, separator).insert(0, splits[0]);
	break;
	}

	workingString = new StringBuilder(splits[0]);

	if (readSize < seekPosition) {
	seekPosition = seekPosition - readSize;
	} else {
	readSize = (int) seekPosition;
	seekPosition = 0;
	}
	}

	f.close();

	returnStr.insert(0, separator).insert(0, "SystemLog:");

	return returnStr.toString();
	}

	/**
	* @return tail of log
	*/
	public static String tailSystemLog(DistributionConfig sc, final int numLines) throws IOException {
	File logFile = sc.getLogFile();
	if (logFile == null \|\| logFile.equals(new File(""))) {
	return null;
	}
	if (!logFile.isAbsolute()) {
	logFile = new File(logFile.getAbsolutePath());
	}
	return tailSystemLog(logFile, numLines);
	}

	public static GemFireProperties initGemfireProperties(DistributionConfig config) {
	String memberGroups = "";
	String configFile = null;
	String includeFile = null;

	GemFireProperties gemFirePropertyData = new GemFireProperties();

	gemFirePropertyData.setMemberName(config.getName());
	gemFirePropertyData.setMemberGroups(memberGroups);
	gemFirePropertyData.setMcastPort(config.getMcastPort());
	gemFirePropertyData.setMcastAddress(config.getMcastAddress().getHostAddress());
	gemFirePropertyData.setBindAddress(config.getBindAddress());
	gemFirePropertyData.setTcpPort(config.getTcpPort());
	gemFirePropertyData.setCacheXMLFile(config.getCacheXmlFile().getAbsolutePath());
	gemFirePropertyData.setConfigFile(configFile);
	gemFirePropertyData.setMcastTTL(config.getMcastTtl());
	gemFirePropertyData.setServerBindAddress(config.getServerBindAddress());
	gemFirePropertyData.setLocators(config.getLocators());
	gemFirePropertyData.setStartLocator(config.getStartLocator());
	gemFirePropertyData.setLogFile(config.getLogFile().getAbsolutePath());
	gemFirePropertyData.setLogLevel(config.getLogLevel());
	gemFirePropertyData.setStatisticSamplingEnabled(config.getStatisticSamplingEnabled());

	gemFirePropertyData.setStatisticArchiveFile(config.getStatisticArchiveFile().getAbsolutePath());
	gemFirePropertyData.setIncludeFile(includeFile);
	gemFirePropertyData.setAckWaitThreshold(config.getAckWaitThreshold());

	gemFirePropertyData.setAckSevereAlertThreshold(config.getAckSevereAlertThreshold());

	gemFirePropertyData.setArchiveFileSizeLimit(config.getArchiveFileSizeLimit());

	gemFirePropertyData.setArchiveDiskSpaceLimit(config.getArchiveDiskSpaceLimit());
	gemFirePropertyData.setLogFileSizeLimit(config.getLogFileSizeLimit());
	gemFirePropertyData.setLogDiskSpaceLimit(config.getLogDiskSpaceLimit());

	gemFirePropertyData.setClusterSSLEnabled(config.getClusterSSLEnabled());
	gemFirePropertyData.setClusterSSLCiphers(config.getClusterSSLCiphers());
	gemFirePropertyData.setClusterSSLProtocols(config.getClusterSSLProtocols());
	gemFirePropertyData
	.setClusterSSLRequireAuthentication(config.getClusterSSLRequireAuthentication());
	gemFirePropertyData.setClusterSSLKeyStore(config.getClusterSSLKeyStore());
	gemFirePropertyData.setClusterSSLKeyStoreType(config.getClusterSSLKeyStoreType());
	gemFirePropertyData.setClusterSSLKeyStorePassword(config.getClusterSSLKeyStorePassword());
	gemFirePropertyData.setClusterSSLTrustStore(config.getClusterSSLTrustStore());
	gemFirePropertyData.setClusterSSLTrustStorePassword(config.getClusterSSLTrustStorePassword());

	gemFirePropertyData.setServerSSLEnabled(config.getServerSSLEnabled());
	gemFirePropertyData.setServerSSLCiphers(config.getServerSSLCiphers());
	gemFirePropertyData.setServerSSLProtocols(config.getServerSSLProtocols());
	gemFirePropertyData
	.setServerSSLRequireAuthentication(config.getServerSSLRequireAuthentication());
	gemFirePropertyData.setServerSSLKeyStore(config.getServerSSLKeyStore());
	gemFirePropertyData.setServerSSLKeyStoreType(config.getServerSSLKeyStoreType());
	gemFirePropertyData.setServerSSLKeyStorePassword(config.getServerSSLKeyStorePassword());
	gemFirePropertyData.setServerSSLTrustStore(config.getServerSSLTrustStore());
	gemFirePropertyData.setServerSSLTrustStorePassword(config.getServerSSLTrustStorePassword());

	gemFirePropertyData.setGatewaySSLEnabled(config.getGatewaySSLEnabled());
	gemFirePropertyData.setGatewaySSLCiphers(config.getGatewaySSLCiphers());
	gemFirePropertyData.setGatewaySSLProtocols(config.getGatewaySSLProtocols());
	gemFirePropertyData
	.setGatewaySSLRequireAuthentication(config.getGatewaySSLRequireAuthentication());
	gemFirePropertyData.setGatewaySSLKeyStore(config.getGatewaySSLKeyStore());
	gemFirePropertyData.setGatewaySSLKeyStoreType(config.getGatewaySSLKeyStoreType());
	gemFirePropertyData.setGatewaySSLKeyStorePassword(config.getGatewaySSLKeyStorePassword());
	gemFirePropertyData.setGatewaySSLTrustStore(config.getGatewaySSLTrustStore());
	gemFirePropertyData.setGatewaySSLTrustStorePassword(config.getGatewaySSLTrustStorePassword());

	gemFirePropertyData.setJmxManagerSSLEnabled(config.getJmxManagerSSLEnabled());
	gemFirePropertyData.setJmxManagerSSLCiphers(config.getJmxManagerSSLCiphers());
	gemFirePropertyData.setJmxManagerSSLProtocols(config.getJmxManagerSSLProtocols());
	gemFirePropertyData
	.setJmxManagerSSLRequireAuthentication(config.getJmxManagerSSLRequireAuthentication());
	gemFirePropertyData.setJmxManagerSSLKeyStore(config.getJmxManagerSSLKeyStore());
	gemFirePropertyData.setJmxManagerSSLKeyStoreType(config.getJmxManagerSSLKeyStoreType());
	gemFirePropertyData.setJmxManagerSSLKeyStorePassword(config.getJmxManagerSSLKeyStorePassword());
	gemFirePropertyData.setJmxManagerSSLTrustStore(config.getJmxManagerSSLTrustStore());
	gemFirePropertyData
	.setJmxManagerSSLTrustStorePassword(config.getJmxManagerSSLTrustStorePassword());

	gemFirePropertyData.setHttpServiceSSLEnabled(config.getHttpServiceSSLEnabled());
	gemFirePropertyData.setHttpServiceSSLCiphers(config.getHttpServiceSSLCiphers());
	gemFirePropertyData.setHttpServiceSSLProtocols(config.getHttpServiceSSLProtocols());
	gemFirePropertyData
	.setHttpServiceSSLRequireAuthentication(config.getHttpServiceSSLRequireAuthentication());
	gemFirePropertyData.setHttpServiceSSLKeyStore(config.getHttpServiceSSLKeyStore());
	gemFirePropertyData.setHttpServiceSSLKeyStoreType(config.getHttpServiceSSLKeyStoreType());
	gemFirePropertyData
	.setHttpServiceSSLKeyStorePassword(config.getHttpServiceSSLKeyStorePassword());
	gemFirePropertyData.setHttpServiceSSLTrustStore(config.getHttpServiceSSLTrustStore());
	gemFirePropertyData
	.setHttpServiceSSLTrustStorePassword(config.getHttpServiceSSLTrustStorePassword());

	gemFirePropertyData.setSocketLeaseTime(config.getSocketLeaseTime());

	gemFirePropertyData.setSocketBufferSize(config.getSocketBufferSize());
	gemFirePropertyData.setMcastSendBufferSize(config.getMcastSendBufferSize());
	gemFirePropertyData.setMcastRecvBufferSize(config.getMcastRecvBufferSize());

	gemFirePropertyData.setMcastByteAllowance(config.getMcastFlowControl().getByteAllowance());
	gemFirePropertyData
	.setMcastRechargeThreshold(config.getMcastFlowControl().getRechargeThreshold());
	gemFirePropertyData.setMcastRechargeBlockMs(config.getMcastFlowControl().getRechargeBlockMs());
	gemFirePropertyData.setUdpFragmentSize(config.getUdpFragmentSize());

	gemFirePropertyData.setUdpRecvBufferSize(config.getUdpRecvBufferSize());
	gemFirePropertyData.setDisableTcp(config.getDisableTcp());

	gemFirePropertyData.setEnableTimeStatistics(config.getEnableTimeStatistics());

	gemFirePropertyData
	.setEnableNetworkPartitionDetection(config.getEnableNetworkPartitionDetection());

	gemFirePropertyData.setMemberTimeout(config.getMemberTimeout());
	gemFirePropertyData.setMembershipPortRange(config.getMembershipPortRange());
	gemFirePropertyData.setConserveSockets(config.getConserveSockets());

	gemFirePropertyData.setRoles(config.getRoles());
	gemFirePropertyData.setMaxWaitTimeForReconnect(config.getMaxWaitTimeForReconnect());

	gemFirePropertyData.setMaxNumReconnectTries(config.getMaxNumReconnectTries());

	gemFirePropertyData.setAsyncDistributionTimeout(config.getAsyncDistributionTimeout());

	gemFirePropertyData.setAsyncQueueTimeout(config.getAsyncQueueTimeout());
	gemFirePropertyData.setAsyncMaxQueueSize(config.getAsyncMaxQueueSize());
	gemFirePropertyData.setClientConflation(config.getClientConflation());

	gemFirePropertyData.setDurableClientId(config.getDurableClientId());
	gemFirePropertyData.setDurableClientTimeout(config.getDurableClientTimeout());
	gemFirePropertyData.setSecurityClientAuthInit(config.getSecurityClientAuthInit());
	gemFirePropertyData.setSecurityClientAuthenticator(config.getSecurityClientAuthenticator());
	gemFirePropertyData.setSecurityClientDHAlgo(config.getSecurityClientDHAlgo());
	gemFirePropertyData.setSecurityPeerAuthInit(config.getSecurityPeerAuthInit());
	gemFirePropertyData.setSecurityPeerAuthenticator(config.getSecurityPeerAuthenticator());
	gemFirePropertyData.setSecurityClientAccessor(config.getSecurityClientAccessor());
	gemFirePropertyData.setSecurityClientAccessorPP(config.getSecurityClientAccessorPP());
	gemFirePropertyData.setSecurityLogLevel(config.getSecurityLogLevel());

	gemFirePropertyData.setSecurityLogFile(config.getSecurityLogFile().getAbsolutePath());

	gemFirePropertyData.setSecurityPeerMembershipTimeout(config.getSecurityPeerMembershipTimeout());

	gemFirePropertyData.setRemoveUnresponsiveClient(config.getRemoveUnresponsiveClient());

	gemFirePropertyData.setDeltaPropagation(config.getDeltaPropagation());
	gemFirePropertyData.setRedundancyZone(config.getRedundancyZone());
	gemFirePropertyData.setEnforceUniqueHost(config.getEnforceUniqueHost());

	gemFirePropertyData.setStatisticSampleRate(config.getStatisticSampleRate());
	gemFirePropertyData.setUdpSendBufferSize(config.getUdpSendBufferSize());

	gemFirePropertyData.setJmxManager(config.getJmxManager());
	gemFirePropertyData.setJmxManagerStart(config.getJmxManagerStart());
	gemFirePropertyData.setJmxManagerPort(config.getJmxManagerPort());
	gemFirePropertyData.setJmxManagerBindAddress(config.getJmxManagerBindAddress());
	gemFirePropertyData.setJmxManagerHostnameForClients(config.getJmxManagerHostnameForClients());
	gemFirePropertyData.setJmxManagerPasswordFile(config.getJmxManagerPasswordFile());
	gemFirePropertyData.setJmxManagerAccessFile(config.getJmxManagerAccessFile());
	gemFirePropertyData.setJmxManagerHttpPort(config.getJmxManagerHttpPort());
	gemFirePropertyData.setJmxManagerUpdateRate(config.getJmxManagerUpdateRate());
	gemFirePropertyData.setHttpServicePort(config.getHttpServicePort());
	gemFirePropertyData.setHttpServiceBindAddress(config.getHttpServiceBindAddress());
	gemFirePropertyData.setStartDevRestApi(config.getStartDevRestApi());

	gemFirePropertyData.setSSLCiphers(config.getSSLCiphers());
	gemFirePropertyData
	.setSecurableCommunicationChannel(config.getSecurableCommunicationChannels());
	gemFirePropertyData
	.setSSLWebServiceRequireAuthentication(config.getSSLWebRequireAuthentication());
	gemFirePropertyData.setSSLKeyStore(config.getSSLKeyStore());
	gemFirePropertyData.setSSLKeyStoreType(config.getSSLKeyStoreType());
	gemFirePropertyData.setSSLKeyStorePassword(config.getSSLKeyStorePassword());

	gemFirePropertyData.setSSLTrustStore(config.getSSLTrustStore());
	gemFirePropertyData.setSSLTrustStorePassword(config.getSSLTrustStorePassword());
	gemFirePropertyData.setSSLTrustStoreType(config.getSSLTrustStoreType());

	gemFirePropertyData.setClusterSSLAlias(config.getClusterSSLAlias());
	gemFirePropertyData.setServerSSLAlias(config.getServerSSLAlias());
	gemFirePropertyData.setJmxSSLAlias(config.getJMXSSLAlias());
	gemFirePropertyData.setGatewaySSLAlias(config.getGatewaySSLAlias());
	gemFirePropertyData.setLocatorSSLAlias(config.getLocatorSSLAlias());
	gemFirePropertyData.setHttpServiceSSLAlias(config.getHTTPServiceSSLAlias());
	gemFirePropertyData.setSSLDefaultAlias(config.getSSLDefaultAlias());

	return gemFirePropertyData;
	}

	/**
	* Compresses a given String. It is encoded using ISO-8859-1, So any decompression of the
	* compressed string should also use ISO-8859-1
	*
	* @param str String to be compressed.
	* @return compressed bytes
	*/
	public static byte[] compress(String str) throws IOException {
	if (str == null \|\| str.length() == 0) {
	return null;
	}
	ByteArrayOutputStream out = new ByteArrayOutputStream();
	GZIPOutputStream gzip = new GZIPOutputStream(out);
	gzip.write(str.getBytes("UTF-8"));
	gzip.close();
	byte[] outBytes = out.toByteArray();
	return outBytes;
	}

	/**
	* @param bytes bytes to be decompressed
	* @return a decompressed String
	*/
	public static String decompress(byte[] bytes) throws IOException {
	if (bytes == null \|\| bytes.length == 0) {
	return null;
	}
	GZIPInputStream gis = new GZIPInputStream(new ByteArrayInputStream(bytes));
	BufferedReader bf = new BufferedReader(new InputStreamReader(gis, "UTF-8"));
	String outStr = "";
	String line;
	while ((line = bf.readLine()) != null) {
	outStr += line;
	}
	return outStr;
	}

	}