mirror of https://github.com/apache/activemq.git
Ensure system safe names are used for container names
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@572975 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
0d0dd4587d
commit
65454017fc
|
@ -217,9 +217,10 @@ public class KahaStore implements Store {
|
|||
return getMapContainer(id, containerName, persistentIndex);
|
||||
}
|
||||
|
||||
public synchronized MapContainer getMapContainer(Object id, String containerName, boolean persistentIndex)
|
||||
public synchronized MapContainer getMapContainer(Object id, String originalContainerName, boolean persistentIndex)
|
||||
throws IOException {
|
||||
initialize();
|
||||
String containerName = IOHelper.toFileSystemSafeName(originalContainerName);
|
||||
ContainerId containerId = new ContainerId();
|
||||
containerId.setKey(id);
|
||||
containerId.setDataContainerName(containerName);
|
||||
|
@ -286,9 +287,10 @@ public class KahaStore implements Store {
|
|||
return getListContainer(id, containerName, persistentIndex);
|
||||
}
|
||||
|
||||
public synchronized ListContainer getListContainer(Object id, String containerName,
|
||||
public synchronized ListContainer getListContainer(Object id, String originalContainerName,
|
||||
boolean persistentIndex) throws IOException {
|
||||
initialize();
|
||||
String containerName = IOHelper.toFileSystemSafeName(originalContainerName);
|
||||
ContainerId containerId = new ContainerId();
|
||||
containerId.setKey(id);
|
||||
containerId.setDataContainerName(containerName);
|
||||
|
|
Loading…
Reference in New Issue